cuddly-jelly-27016
02/12/2025, 2:24 AMflyte_remote.execute(ref_t1, dict(a=["foo", "bar"]))
Currently this code runs (because RemoteTask extends PythonTask and is treated as such), but ignores the version (and probably domain and project) - runs with the latest registered version of that task.
Goal: What should the final outcome look like, ideally?
Ideally I'd want to run any ReferenceEntity with
flyte_remote.execute(ref_entity, inputs=...)
And execute would respect all set values.
For consistency with the other types, methods like FlyteRemote.execute_reference_X()
would have to be introduced too.
Describe alternatives you've considered
This is a working work-around:
flyte_remote.execute(ref_entity, version=ref_entity.id.version, inputs=...)
(Not considering project/domain, but same thing should work).
Propose: Link/Inline OR Additional context
Note: I'm happy to create a PR to flytekit if this change is reasonable.
Are you sure this issue hasn't been raised already?
• Yes
Have you read the Code of Conduct?
• Yes
flyteorg/flytecuddly-jelly-27016
02/12/2025, 2:24 AM