aspain commented on PR #23424: URL: https://github.com/apache/airflow/pull/23424#issuecomment-1115428277
I copied the example DAG as-is from the [Task-generated Mapping](https://airflow.apache.org/docs/apache-airflow/2.3.0/concepts/dynamic-task-mapping.html#task-generated-mapping) section which results in the first 2 mapped tasks failing:  Task log error: ``` [2022-05-02, 22:20:26 UTC] {taskinstance.py:1888} ERROR - Task failed with exception Traceback (most recent call last): File "/usr/local/lib/python3.9/site-packages/airflow/decorators/base.py", line 179, in execute return_value = super().execute(context) File "/usr/local/lib/python3.9/site-packages/airflow/operators/python.py", line 171, in execute return_value = self.execute_callable() File "/usr/local/lib/python3.9/site-packages/airflow/operators/python.py", line 189, in execute_callable return self.python_callable(*self.op_args, **self.op_kwargs) File "/usr/local/airflow/dags/dyn2.py", line 15, in consumer print(list(arg)) TypeError: 'int' object is not iterable [2022-05-02, 22:20:26 UTC] {taskinstance.py:1394} INFO - Marking task as FAILED. dag_id=dynamic-map2, task_id=consumer, map_index=0, execution_date=20220412T000000, start_date=20220502T222026, end_date=20220502T222026 [2022-05-02, 22:20:26 UTC] {standard_task_runner.py:92} ERROR - Failed to execute job 909 for task consumer ('int' object is not iterable; 390) [2022-05-02, 22:20:26 UTC] {local_task_job.py:156} INFO - Task exited with return code 1 ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
