Frank Shen
01/30/2023, 11:58 PMKetan (kumare3)
Frank Shen
01/31/2023, 12:54 AMKetan (kumare3)
@task(cache=True, cache_version="1.0")
def t1() -> int:
...
@workflow
def wf1():
t1()
@task
def t2(i: int) -> float:
...
@workflow
def wf2():
i = t1()
t2(i=i)
Frank Shen
01/31/2023, 12:59 AMKetan (kumare3)
Eduardo Apolinario (eapolinario)
02/01/2023, 6:23 PMFrank Shen
02/01/2023, 7:20 PM