Jason Raede
12/24/2021, 9:08 PM@task
def task1():
return Object(foo='bar')
@task
def task2(foo: str):
// Do something
@task
def getfoo(o: Object):
return o.foo
with Flow('my-flow'):
task1_result = task1()
// This fails
task2(task1_result.foo)
// This works, but is annoying
task2(getfoo(task1_result))
Kevin Kho
task1_result()
is still a Task here and it only resolves during Flow execution to the object. I think this should be doable in Prefect Orion (Prefect 2.0)Jason Raede
12/28/2021, 12:30 AM