Re: [I] timeout on Dynamic Task mapping : skipped inner task , task status is still success [airflow]

Mon, 25 Mar 2024 13:18:59 -0700 


raphaelauv commented on issue #37332:
URL: https://github.com/apache/airflow/issues/37332#issuecomment-2018836100

   I don''t understand , what is your question ?
   
   --
   
   also the problem is not present without dynamic task mapping
   
![image](https://github.com/apache/airflow/assets/10202690/aeedf516-324a-4f2e-8067-1756e759de03)
   
   ```python
   from datetime import timedelta
   from airflow.operators.python import PythonOperator
   from pendulum import today
   from airflow import DAG
   
   dag = DAG(
       dag_id="test_dag",
       schedule_interval=None,
       dagrun_timeout=timedelta(seconds=5),
       start_date=today("UTC").add(days=-1)
   )
   
   with dag:
       def something(arg):
           import time
           time.sleep(int(arg))
   
       PythonOperator(
           task_id="toto",
           python_callable=something,
           op_args="10")
       PythonOperator(
           task_id="tata",
           python_callable=something,
           op_args="10")
   ``


-- 
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]

Reply via email to