acoustic-carpenter-78188
04/27/2023, 10:00 PM@reference_task(
project="flytesnacks",
domain="development",
name="recipes.aaa.simple.join_strings",
version="553018f39e519bdb2597b652639c30ce16b99c79",
)
def ref_t1(a: typing.List[str]) -> str:
...
I would like to be able to call it with FlyteRemote.execute:
flyte_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/flyte