hard20 pts · first answer countsairflowairflow-dynamic-task-mappingairflow-xcom

Summing results of mapped tasks

count_rows is mapped over 12 files and returns an int each. A normal downstream task total(counts) receives count_rows's output. What is counts?

counts = count_rows.expand(path=files)
total(counts)

A.Only the value from the last mapped instanceB.A sequence of the 12 returned intsC.The sum of the 12 ints, added by AirflowD.None, because mapped tasks cannot return values

Discussion 0

Join free to post in the discussion.

Summing results of mapped tasks

Discussion 0

Related questions