@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)
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.