joshua mclellan
06/14/2021, 3:17 PMZach Schumacher
06/14/2021, 3:19 PMZach Schumacher
06/14/2021, 3:19 PMKevin Kho
@task()
def add_ten(x):
print(f'starting {x}')
sleep(10)
print(f'ending {x}')
return x * 2
with Flow('simple map') as flow:
t = add_ten.map([1, 2, 3])
s = add_ten.map([10, 20, 30])
with Flow('simple map2') as flow2:
t = add_ten.map([1, 2])
flow.register('project')
flow2.register('project')
Kevin Kho
Kevin Kho
task.run()
also, but this won’t run all the dependencies attached.