acoustic-carpenter-78188
04/05/2023, 4:56 AMFailed with Unknown Exception <class 'AttributeError'> Reason: 'ReferenceTask' object has no attribute '_task_function' error.
Expected behavior
This operation shouldn't result in any errors.
Additional context to reproduce
1. Clone the flytesnacks repo
2. Register the decorating tasks example
3. Trigger the following code by specifying the registered version of task t1
from flytekit import map_task, reference_task, workflow
@reference_task(
project="flytesnacks",
domain="development",
name="core.flyte_basics.decorating_tasks.t1",
version="<version>",
)
def t1(x: int) -> int:
...
@workflow
def wf(x: list[int] = [3, 2]):
return map_task(t1)(x=x)
Screenshots
No response
Are you sure this issue hasn't been raised already?
☑︎ Yes
Have you read the Code of Conduct?
☑︎ Yes
flyteorg/flyte