RNHTTR commented on issue #34023:
URL: https://github.com/apache/airflow/issues/34023#issuecomment-1703962890
Like @benbuckman reported, the task was skipped before `fake_sensor` ran.
debug logs:
```
[2023-09-02T23:21:23.108+0000] {retries.py:92} DEBUG - Running
SchedulerJobRunner._schedule_all_dag_runs with retries. Try 1 of 3
[2023-09-02T23:21:23.110+0000] {scheduler_job_runner.py:1485} DEBUG - DAG
demo_trigger_one_failed not changed structure, skipping dagrun.verify_integrity
[2023-09-02T23:21:23.111+0000] {dagrun.py:740} DEBUG - number of tis tasks
for <DagRun demo_trigger_one_failed @ 2023-09-02 23:21:21.860553+00:00:
manual__2023-09-02T23:21:21.860553+00:00, state:running, queued_at: 2023-09-02
23:21:21.885385+00:00. externally triggered: True>: 6 task(s)
[2023-09-02T23:21:23.112+0000] {dagrun.py:761} DEBUG - number of
scheduleable tasks for <DagRun demo_trigger_one_failed @ 2023-09-02
23:21:21.860553+00:00: manual__2023-09-02T23:21:21.860553+00:00, state:running,
queued_at: 2023-09-02 23:21:21.885385+00:00. externally triggered: True>: 2
task(s)
[2023-09-02T23:21:23.116+0000] {taskinstance.py:1168} DEBUG - <TaskInstance:
demo_trigger_one_failed.deliver_records.fake_sensor
manual__2023-09-02T23:21:21.860553+00:00 [None]> dependency 'Previous Dagrun
State' PASSED: True, The task did not have depends_on_past set.
[2023-09-02T23:21:23.116+0000] {taskinstance.py:1168} DEBUG - <TaskInstance:
demo_trigger_one_failed.deliver_records.fake_sensor
manual__2023-09-02T23:21:21.860553+00:00 [None]> dependency 'Not In Retry
Period' PASSED: True, The task instance was not marked for retrying.
[2023-09-02T23:21:23.116+0000] {taskinstance.py:1159} DEBUG - Dependencies
all met for dep_context=None ti=<TaskInstance:
demo_trigger_one_failed.deliver_records.fake_sensor
manual__2023-09-02T23:21:21.860553+00:00 [None]>
[2023-09-02T23:21:23.210+0000] {abstractoperator.py:573} DEBUG - Updated in
place to become <TaskInstance:
demo_trigger_one_failed.deliver_records.fake_sensor
manual__2023-09-02T23:21:21.860553+00:00 map_index=0 [None]>
[2023-09-02T23:21:23.215+0000] {abstractoperator.py:598} DEBUG - Expanding
TIs upserted <TaskInstance: demo_trigger_one_failed.deliver_records.fake_sensor
manual__2023-09-02T23:21:21.860553+00:00 map_index=1 [None]>
[2023-09-02T23:21:23.218+0000] {abstractoperator.py:598} DEBUG - Expanding
TIs upserted <TaskInstance: demo_trigger_one_failed.deliver_records.fake_sensor
manual__2023-09-02T23:21:21.860553+00:00 map_index=2 [None]>
[2023-09-02T23:21:23.224+0000] {taskinstance.py:956} DEBUG - Setting task
state for <TaskInstance:
demo_trigger_one_failed.deliver_records.handle_failed_delivery
manual__2023-09-02T23:21:21.860553+00:00 [None]> to skipped
[2023-09-02T23:21:23.224+0000] {taskinstance.py:1168} DEBUG - <TaskInstance:
demo_trigger_one_failed.deliver_records.handle_failed_delivery
manual__2023-09-02T23:21:21.860553+00:00 [skipped]> dependency 'Trigger Rule'
PASSED: False, Task's trigger rule 'one_failed' requires one upstream task
failure, but none were found. upstream_states=_UpstreamTIStates(success=1,
skipped=0, failed=0, upstream_failed=0, removed=0, done=1, success_setup=0,
skipped_setup=0), upstream_task_ids={'get_records',
'deliver_records.fake_sensor'}
[2023-09-02T23:21:23.224+0000] {taskinstance.py:1149} DEBUG - Dependencies
not met for <TaskInstance:
demo_trigger_one_failed.deliver_records.handle_failed_delivery
manual__2023-09-02T23:21:21.860553+00:00 [skipped]>, dependency 'Trigger Rule'
FAILED: Task's trigger rule 'one_failed' requires one upstream task failure,
but none were found. upstream_states=_UpstreamTIStates(success=1, skipped=0,
failed=0, upstream_failed=0, removed=0, done=1, success_setup=0,
skipped_setup=0), upstream_task_ids={'get_records',
'deliver_records.fake_sensor'}
[2023-09-02T23:21:23.224+0000] {taskinstance.py:1168} DEBUG - <TaskInstance:
demo_trigger_one_failed.deliver_records.handle_failed_delivery
manual__2023-09-02T23:21:21.860553+00:00 [skipped]> dependency 'Previous Dagrun
State' PASSED: True, The task did not have depends_on_past set.
[2023-09-02T23:21:23.224+0000] {taskinstance.py:1168} DEBUG - <TaskInstance:
demo_trigger_one_failed.deliver_records.handle_failed_delivery
manual__2023-09-02T23:21:21.860553+00:00 [skipped]> dependency 'Not In Retry
Period' PASSED: True, The task instance was not marked for retrying.
[2023-09-02T23:21:23.226+0000] {taskinstance.py:1168} DEBUG - <TaskInstance:
demo_trigger_one_failed.deliver_records.fake_sensor
manual__2023-09-02T23:21:21.860553+00:00 map_index=0 [None]> dependency
'Trigger Rule' PASSED: False, Task's trigger rule 'all_success' requires all
upstream tasks to have succeeded, but found 1 non-success(es).
upstream_states=_UpstreamTIStates(success=1, skipped=0, failed=0,
upstream_failed=0, removed=0, done=1, success_setup=0, skipped_setup=0),
upstream_task_ids={'get_records', 'deliver_records.submit_job'}
[2023-09-02T23:21:23.226+0000] {taskinstance.py:1149} DEBUG - Dependencies
not met for <TaskInstance: demo_trigger_one_failed.deliver_records.fake_sensor
manual__2023-09-02T23:21:21.860553+00:00 map_index=0 [None]>, dependency
'Trigger Rule' FAILED: Task's trigger rule 'all_success' requires all upstream
tasks to have succeeded, but found 1 non-success(es).
upstream_states=_UpstreamTIStates(success=1, skipped=0, failed=0,
upstream_failed=0, removed=0, done=1, success_setup=0, skipped_setup=0),
upstream_task_ids={'get_records', 'deliver_records.submit_job'}
[2023-09-02T23:21:23.226+0000] {taskinstance.py:1168} DEBUG - <TaskInstance:
demo_trigger_one_failed.deliver_records.fake_sensor
manual__2023-09-02T23:21:21.860553+00:00 map_index=0 [None]> dependency
'Previous Dagrun State' PASSED: True, The task did not have depends_on_past set.
[2023-09-02T23:21:23.226+0000] {taskinstance.py:1168} DEBUG - <TaskInstance:
demo_trigger_one_failed.deliver_records.fake_sensor
manual__2023-09-02T23:21:21.860553+00:00 map_index=0 [None]> dependency 'Not In
Retry Period' PASSED: True, The task instance was not marked for retrying.
[2023-09-02T23:21:23.229+0000] {taskinstance.py:1168} DEBUG - <TaskInstance:
demo_trigger_one_failed.deliver_records.fake_sensor
manual__2023-09-02T23:21:21.860553+00:00 map_index=1 [None]> dependency
'Trigger Rule' PASSED: False, Task's trigger rule 'all_success' requires all
upstream tasks to have succeeded, but found 1 non-success(es).
upstream_states=_UpstreamTIStates(success=1, skipped=0, failed=0,
upstream_failed=0, removed=0, done=1, success_setup=0, skipped_setup=0),
upstream_task_ids={'get_records', 'deliver_records.submit_job'}
[2023-09-02T23:21:23.229+0000] {taskinstance.py:1149} DEBUG - Dependencies
not met for <TaskInstance: demo_trigger_one_failed.deliver_records.fake_sensor
manual__2023-09-02T23:21:21.860553+00:00 map_index=1 [None]>, dependency
'Trigger Rule' FAILED: Task's trigger rule 'all_success' requires all upstream
tasks to have succeeded, but found 1 non-success(es).
upstream_states=_UpstreamTIStates(success=1, skipped=0, failed=0,
upstream_failed=0, removed=0, done=1, success_setup=0, skipped_setup=0),
upstream_task_ids={'get_records', 'deliver_records.submit_job'}
[2023-09-02T23:21:23.229+0000] {taskinstance.py:1168} DEBUG - <TaskInstance:
demo_trigger_one_failed.deliver_records.fake_sensor
manual__2023-09-02T23:21:21.860553+00:00 map_index=1 [None]> dependency
'Previous Dagrun State' PASSED: True, The task did not have depends_on_past set.
[2023-09-02T23:21:23.229+0000] {taskinstance.py:1168} DEBUG - <TaskInstance:
demo_trigger_one_failed.deliver_records.fake_sensor
manual__2023-09-02T23:21:21.860553+00:00 map_index=1 [None]> dependency 'Not In
Retry Period' PASSED: True, The task instance was not marked for retrying.
[2023-09-02T23:21:23.232+0000] {taskinstance.py:1168} DEBUG - <TaskInstance:
demo_trigger_one_failed.deliver_records.fake_sensor
manual__2023-09-02T23:21:21.860553+00:00 map_index=2 [None]> dependency
'Trigger Rule' PASSED: False, Task's trigger rule 'all_success' requires all
upstream tasks to have succeeded, but found 1 non-success(es).
upstream_states=_UpstreamTIStates(success=1, skipped=0, failed=0,
upstream_failed=0, removed=0, done=1, success_setup=0, skipped_setup=0),
upstream_task_ids={'get_records', 'deliver_records.submit_job'}
[2023-09-02T23:21:23.232+0000] {taskinstance.py:1149} DEBUG - Dependencies
not met for <TaskInstance: demo_trigger_one_failed.deliver_records.fake_sensor
manual__2023-09-02T23:21:21.860553+00:00 map_index=2 [None]>, dependency
'Trigger Rule' FAILED: Task's trigger rule 'all_success' requires all upstream
tasks to have succeeded, but found 1 non-success(es).
upstream_states=_UpstreamTIStates(success=1, skipped=0, failed=0,
upstream_failed=0, removed=0, done=1, success_setup=0, skipped_setup=0),
upstream_task_ids={'get_records', 'deliver_records.submit_job'}
[2023-09-02T23:21:23.232+0000] {taskinstance.py:1168} DEBUG - <TaskInstance:
demo_trigger_one_failed.deliver_records.fake_sensor
manual__2023-09-02T23:21:21.860553+00:00 map_index=2 [None]> dependency
'Previous Dagrun State' PASSED: True, The task did not have depends_on_past set.
[2023-09-02T23:21:23.232+0000] {taskinstance.py:1168} DEBUG - <TaskInstance:
demo_trigger_one_failed.deliver_records.fake_sensor
manual__2023-09-02T23:21:21.860553+00:00 map_index=2 [None]> dependency 'Not In
Retry Period' PASSED: True, The task instance was not marked for retrying.
[2023-09-02T23:21:23.236+0000] {scheduler_job_runner.py:1512} DEBUG -
Skipping SLA check for <DAG: demo_trigger_one_failed> because no tasks in DAG
have SLAs
[2023-09-02T23:21:23.236+0000] {scheduler_job_runner.py:1504} DEBUG -
callback is empty
[2023-09-02T23:21:23.241+0000] {scheduler_job_runner.py:414} INFO - 3 tasks
up for execution:
<TaskInstance: demo_trigger_one_failed.deliver_records.submit_job
manual__2023-09-02T23:21:21.860553+00:00 map_index=0 [scheduled]>
<TaskInstance: demo_trigger_one_failed.deliver_records.submit_job
manual__2023-09-02T23:21:21.860553+00:00 map_index=1 [scheduled]>
<TaskInstance: demo_trigger_one_failed.deliver_records.submit_job
manual__2023-09-02T23:21:21.860553+00:00 map_index=2 [scheduled]>
```
--
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]
