Matthias
07/17/2020, 2:15 PM@task(checkpoint=False)
def extract_things():
bar = [1, 2, 3, 4, 5, 6, 7, 8, 9]
foo = ['a', 'b', 'c']
data = {
'bar': bar,
'foo': foo
}
return data
@task(checkpoint=False)
def do_things(data):
for x in data:
print(x)
return None
with Flow(
"Do it",
) as flow:
things = extract_things()
do_things(things['foo'])
do_things(things['bar'])
nicholas
07/17/2020, 2:43 PMMatthias
07/17/2020, 2:44 PMnicholas
07/17/2020, 2:44 PMMatthias
07/17/2020, 2:45 PMnicholas
07/17/2020, 3:00 PMMatthias
07/17/2020, 3:02 PMnicholas
07/17/2020, 3:08 PMthings['foo']
and things['bar']
directly when passing the result into your downstream tasks, which is turning them into a Constant
task. You should instead access those props by mapping over them or accessing the keys directly in your tasks.Matthias
07/17/2020, 3:09 PMnicholas
07/17/2020, 3:14 PMMatthias
07/17/2020, 3:15 PM