Lana Dann
Kevin Kho
Zanie
tuples = [(1, 1), (2, 2), (3, 4)] map_task = task(lambda x, y: x + y) with Flow('Tuple Maps') as flow: map_task.map(tuples)
TypeError: missing a required argument: 'y'
@task def map_task(tup): x, y = tup return x + y ... map_task.map(tuples)
tuples
List[Tuple]
Tuple[List]
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.