Igor Bondartsov
04/08/2021, 5:03 AMJay Shah
04/08/2021, 11:47 AMimport packages
@task
def some_func():
return
with flow("my-flow") as flow:
some_func_task=some_func()
flow.run()
Zach Angell
@task
def my_duplicated_task(idx):
# do something
@task
def return_range(x):
return [i for i in range(x)
with Flow('sample') as flow:
x = Parameter(default=5)
xrange = return_range(x)
mapped_tasks = my_duplicated_task.map(xrange)