ephraimbuddy commented on issue #25200:
URL: https://github.com/apache/airflow/issues/25200#issuecomment-1195248602

   The error at the scheduler log:
   ```
   2022-07-26 09:26:49,032] {dag.py:3084} INFO - Setting next_dagrun for 
break_mapping to 2022-05-21T00:00:00+00:00, run_after=2022-05-22T00:00:00+00:00
   [2022-07-26 09:26:49,090] {mappedoperator.py:665} INFO - Marking 
<TaskInstance: break_mapping.add_one scheduled__2022-05-07T00:00:00+00:00 
[None]> as SKIPPED since the map has 0 values to expand
   [2022-07-26 09:26:49,113] {dagrun.py:588} ERROR - Deadlock; marking run 
<DagRun break_mapping @ 2022-05-07 00:00:00+00:00: 
scheduled__2022-05-07T00:00:00+00:00, state:running, queued_at: 2022-07-26 
09:26:46.876995+00:00. externally triggered: False> failed
   ```
   The task log for the successful task with failed dagrun(last lines), the two 
other tasks were skipped as expected:
   ```
   [2022-07-26, 09:26:48 UTC] {logging_mixin.py:115} INFO - Hi
   [2022-07-26, 09:26:48 UTC] {python.py:173} INFO - Done. Returned value was: 
None
   [2022-07-26, 09:26:48 UTC] {taskinstance.py:1393} INFO - Marking task as 
SUCCESS. dag_id=break_mapping, task_id=say_hi, execution_date=20220507T000000, 
start_date=20220726T092647, end_date=20220726T092648
   [2022-07-26, 09:26:49 UTC] {local_task_job.py:163} INFO - Task exited with 
return code 0
   [2022-07-26, 09:26:49 UTC] {local_task_job.py:272} INFO - 0 downstream tasks 
scheduled from follow-on schedule check
   ```
   The task log for the successful task with successful dagrun(last lines), the 
two other tasks were skipped as expected:
   ```
   [2022-07-26, 09:26:43 UTC] {logging_mixin.py:115} INFO - Hi
   [2022-07-26, 09:26:43 UTC] {python.py:173} INFO - Done. Returned value was: 
None
   [2022-07-26, 09:26:43 UTC] {taskinstance.py:1393} INFO - Marking task as 
SUCCESS. dag_id=break_mapping, task_id=say_hi, execution_date=20220503T000000, 
start_date=20220726T092641, end_date=20220726T092643
   [2022-07-26, 09:26:43 UTC] {local_task_job.py:163} INFO - Task exited with 
return code 0
   [2022-07-26, 09:26:43 UTC] {mappedoperator.py:665} INFO - Marking 
<TaskInstance: break_mapping.add_one scheduled__2022-05-03T00:00:00+00:00 
[None]> as SKIPPED since the map has 0 values to expand
   [2022-07-26, 09:26:43 UTC] {local_task_job.py:272} INFO - 0 downstream tasks 
scheduled from follow-on schedule check
   ```
   


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