numerous-hamburger-7178
10/12/2023, 8:12 PM>>
? Seeing this error when trying to chain tasks inside a dynamic task
File "/usr/local/lib/python3.9/site-packages/flytekit/core/promise.py", line 297, in __rshift__
if not self.is_ready and other.ref:
Message:
'Output' object has no attribute 'ref'
numerous-hamburger-7178
10/12/2023, 8:40 PMthankful-minister-83577
thankful-minister-83577
numerous-hamburger-7178
10/12/2023, 11:15 PMnumerous-hamburger-7178
10/12/2023, 11:24 PMnumerous-hamburger-7178
10/12/2023, 11:24 PMthankful-minister-83577
numerous-hamburger-7178
10/12/2023, 11:32 PMnumerous-hamburger-7178
10/12/2023, 11:35 PMthankful-minister-83577
numerous-hamburger-7178
10/12/2023, 11:35 PMfrom flytekit import dynamic, task, workflow
from typing import Tuple
@task
def task_2(
condition: bool
) -> str:
return str(condition)
@task
def task_3(
condition: bool
) -> Tuple[str, str]:
return str(condition), str(not condition)
@dynamic
def dynamic_1(
condition: bool
):
job3 = task_2(
condition=condition
)
job4 = task_3(
condition=condition
)
job3 >> job4
@workflow
def wf_2(
condition: bool
):
dynamic_1(
condition=condition
)
thankful-minister-83577
thankful-minister-83577
job4, job5 = task_3(
condition=condition
)
numerous-hamburger-7178
10/12/2023, 11:38 PMnumerous-hamburger-7178
10/12/2023, 11:38 PMnumerous-hamburger-7178
10/12/2023, 11:39 PMnumerous-hamburger-7178
10/12/2023, 11:39 PMjob4, job5 = task_3(
condition=condition
)
job3 >> job4
thankful-minister-83577
white-teacher-47376
11/22/2023, 2:24 PM@task
def task1() -> None:
print("Task1")
Task2Out = NamedTuple("Task2Out", out1=int, out2=int)
@task
def task2() -> Task2Out:
return Task2Out(1, 2)
@workflow
def demo_wf() -> None:
out1 = task1()
out2 = task2()
out1 >> out2
thankful-minister-83577
out1 >> out2.out1
white-teacher-47376
11/23/2023, 7:59 AM