How to dynamically iterate over the output of an upstream task to create parallel tasks in airflow? How to dynamically iterate over the output of an upstream task to create parallel tasks in airflow? python-3.x python-3.x