amoghrajesh commented on PR #59711:
URL: https://github.com/apache/airflow/pull/59711#issuecomment-3686806768
Oh nice, our tests caught this:
```python
_____________________________________________________________________________
TestCliDags.test_dag_test_no_triggerer_running
_____________________________________________________________________________
airflow-core/tests/unit/cli/commands/test_dag_command.py:926: in
test_dag_test_no_triggerer_running
trigger_arg = mock_run.call_args_list[0].args[0]
E IndexError: list index out of range
-----------------------------------------------------------------------------------------
Captured stdout setup
------------------------------------------------------------------------------------------
2025-12-23T12:58:10.452614Z [info ] Filling up the DagBag from /dev/null
[airflow.dag_processing.dagbag.DagBag]
------------------------------------------------------------------------------------------
Captured stdout call
------------------------------------------------------------------------------------------
2025-12-23T12:58:10.470013Z [info ] Bulk-writing dags to db
[airflow.serialization.definitions.dag] count=1
2025-12-23T12:58:10.476333Z [info ] Creating ORM DAG for test_dag
[airflow.dag_processing.collection]
2025-12-23T12:58:10.507290Z [info ] Bulk-writing dags to db
[airflow.serialization.definitions.dag] count=1
2025-12-23T12:58:10.574004Z [info ] Created dag run.
[airflow.models.dagrun] dagrun=<DagRun test_dag @ 2025-12-23
12:58:10.558813+00:00: manual__2025-12-23T12:58:10.561367+00:00, state:running,
queued_at: None. run_type: manual>
2025-12-23T12:58:17.598354Z [info ] Task started
[airflow.api_fastapi.execution_api.routes.task_instances]
correlation_id=019b4b49-ddd1-7e6d-afc8-4de964bc71c0 hostname=8b21455fe38d
previous_state=queued ti_id=019b4b49-dd0f-7a5f-9742-e0149b234f23
2025-12-23T12:58:17.601445Z [info ] Task instance state updated
[airflow.api_fastapi.execution_api.routes.task_instances]
correlation_id=019b4b49-ddd1-7e6d-afc8-4de964bc71c0 rows_affected=1
ti_id=019b4b49-dd0f-7a5f-9742-e0149b234f23
2025-12-23T12:58:17.633702Z [info ] Updating RenderedTaskInstanceFields
[airflow.api_fastapi.execution_api.routes.task_instances]
correlation_id=019b4b49-f899-7c8a-9fa9-0296222f7877 field_count=3
ti_id=019b4b49-dd0f-7a5f-9742-e0149b234f23
Task instance is in running state
Previous state of the Task instance: TaskInstanceState.QUEUED
Current task name:one
Dag name:test_dag
2025-12-23T12:58:17.668443Z [info ] Done. Returned value was: 1
[airflow.task.operators.airflow.providers.standard.decorators.python._PythonDecoratedOperator]
2025-12-23T12:58:17.668740Z [info ] Pushing xcom
[task] ti=RuntimeTaskInstance(id=UUID('019b4b49-dd0f-7a5f-9742-e0149b234f23'),
task_id='one', dag_id='test_dag',
run_id='manual__2025-12-23T12:58:10.561367+00:00', try_number=1,
dag_version_id=UUID('019b4b49-dcba-79f7-a75e-d211b74c311f'), map_index=-1,
hostname='8b21455fe38d', context_carrier=None,
task=<Task(_PythonDecoratedOperator): one>, max_tries=0,
start_date=datetime.datetime(2025, 12, 23, 12, 58, 10, 768355,
tzinfo=datetime.timezone.utc), end_date=None, state=<TaskInstanceState.RUNNING:
'running'>, is_mapped=False, rendered_map_index=None, sentry_integration='')
[] []
2025-12-23T12:58:17.723593Z [info ] Task instance state updated
[airflow.api_fastapi.execution_api.routes.task_instances]
correlation_id=019b4b49-f8db-78db-9670-1f8bf1d20ab1 new_state=success
rows_affected=1 ti_id=019b4b49-dd0f-7a5f-9742-e0149b234f23
Task instance in success state
Previous state of the Task instance: TaskInstanceState.RUNNING
Task operator:<Task(_PythonDecoratedOperator): one>
2025-12-23T12:58:23.665362Z [info ] Task started
[airflow.api_fastapi.execution_api.routes.task_instances]
correlation_id=019b4b49-f9c8-7114-9e6a-84cb9fc092f8 hostname=8b21455fe38d
previous_state=queued ti_id=019b4b49-dd10-7b33-8b2f-9c02cb38fd95
2025-12-23T12:58:23.667468Z [info ] Task instance state updated
[airflow.api_fastapi.execution_api.routes.task_instances]
correlation_id=019b4b49-f9c8-7114-9e6a-84cb9fc092f8 rows_affected=1
ti_id=019b4b49-dd10-7b33-8b2f-9c02cb38fd95
2025-12-23T12:58:23.714198Z [info ] Updating RenderedTaskInstanceFields
[airflow.api_fastapi.execution_api.routes.task_instances]
correlation_id=019b4b4a-105a-7b44-920f-f0ef7d4863f1 field_count=3
ti_id=019b4b49-dd10-7b33-8b2f-9c02cb38fd95
Task instance is in running state
Previous state of the Task instance: TaskInstanceState.QUEUED
Current task name:two
Dag name:test_dag
2025-12-23T12:58:23.727615Z [info ] Done. Returned value was: 2
[airflow.task.operators.airflow.providers.standard.decorators.python._PythonDecoratedOperator]
2025-12-23T12:58:23.727823Z [info ] Pushing xcom
[task] ti=RuntimeTaskInstance(id=UUID('019b4b49-dd10-7b33-8b2f-9c02cb38fd95'),
task_id='two', dag_id='test_dag',
run_id='manual__2025-12-23T12:58:10.561367+00:00', try_number=1,
dag_version_id=UUID('019b4b49-dcba-79f7-a75e-d211b74c311f'), map_index=-1,
hostname='8b21455fe38d', context_carrier=None,
task=<Task(_PythonDecoratedOperator): two>, max_tries=0,
start_date=datetime.datetime(2025, 12, 23, 12, 58, 17, 927759,
tzinfo=datetime.timezone.utc), end_date=None, state=<TaskInstanceState.RUNNING:
'running'>, is_mapped=False, rendered_map_index=None, sentry_integration='')
[] []
2025-12-23T12:58:23.765383Z [info ] Task instance state updated
[airflow.api_fastapi.execution_api.routes.task_instances]
correlation_id=019b4b4a-1083-788d-b197-44b1b1c6ca07 new_state=success
rows_affected=1 ti_id=019b4b49-dd10-7b33-8b2f-9c02cb38fd95
Task instance in success state
Previous state of the Task instance: TaskInstanceState.RUNNING
Task operator:<Task(_PythonDecoratedOperator): two>
2025-12-23T12:58:28.280891Z [info ] Task started
[airflow.api_fastapi.execution_api.routes.task_instances]
correlation_id=019b4b4a-1155-79b9-b186-3f52a5e2efb6 hostname=8b21455fe38d
previous_state=queued ti_id=019b4b49-dd11-7233-910e-7c2d5fc1768c
2025-12-23T12:58:28.282852Z [info ] Task instance state updated
[airflow.api_fastapi.execution_api.routes.task_instances]
correlation_id=019b4b4a-1155-79b9-b186-3f52a5e2efb6 rows_affected=1
ti_id=019b4b49-dd11-7233-910e-7c2d5fc1768c
2025-12-23T12:58:28.316970Z [info ] Updating RenderedTaskInstanceFields
[airflow.api_fastapi.execution_api.routes.task_instances]
correlation_id=019b4b4a-2256-7aa9-97ca-ebbb5e945c53 field_count=1
ti_id=019b4b49-dd11-7233-910e-7c2d5fc1768c
Task instance is in running state
Previous state of the Task instance: TaskInstanceState.QUEUED
Current task name:abc
Dag name:test_dag
I AM DEFERRING
2025-12-23T12:58:28.328706Z [info ] Pausing task as DEFERRED.
[task] dag_id=test_dag run_id=manual__2025-12-23T12:58:10.561367+00:00
task_id=abc
2025-12-23T12:58:28.343552Z [info ] Task instance state updated
[airflow.api_fastapi.execution_api.routes.task_instances]
correlation_id=019b4b4a-2269-720f-8be0-308a986d712e new_state=deferred
rows_affected=1 ti_id=019b4b49-dd11-7233-910e-7c2d5fc1768c
2025-12-23T12:58:28.373015Z [info ] Marking run <DagRun test_dag @
2025-12-23 12:58:10.558813+00:00: manual__2025-12-23T12:58:10.561367+00:00,
state:running, queued_at: None. run_type: manual> failed
[airflow.models.dagrun.DagRun]
Dag run in failure state
Dag information:test_dag Run id: manual__2025-12-23T12:58:10.561367+00:00
Run type: manual
Failed with message: task_failure
2025-12-23T12:58:28.373278Z [info ] DagRun Finished: dag_id=test_dag,
logical_date=2025-12-23 12:58:10.558813+00:00,
run_id=manual__2025-12-23T12:58:10.561367+00:00, run_start_date=2025-12-23
12:58:10.558813+00:00, run_end_date=2025-12-23 12:58:28.373122+00:00,
run_duration=17.814309, state=failed, run_type=manual,
data_interval_start=2025-12-22 12:58:10.558813+00:00,
data_interval_end=2025-12-23 12:58:10.558813+00:00,
[airflow.models.dagrun.DagRun]
------------------------------------------------------------------------------------------
Captured stderr call
------------------------------------------------------------------------------------------
2025-12-23T12:58:10.601998Z [info ] [DAG TEST] starting task_id=one
map_index=-1 [airflow.sdk.definitions.dag]
2025-12-23T12:58:10.603273Z [info ] [DAG TEST] running task
<TaskInstance: test_dag.one manual__2025-12-23T12:58:10.561367+00:00
[scheduled]> [airflow.sdk.definitions.dag]
2025-12-23T12:58:17.747317Z [info ] [DAG TEST] end task task_id=one
map_index=-1 [airflow.sdk.definitions.dag]
2025-12-23T12:58:17.760542Z [info ] [DAG TEST] starting task_id=two
map_index=-1 [airflow.sdk.definitions.dag]
2025-12-23T12:58:17.760831Z [info ] [DAG TEST] running task
<TaskInstance: test_dag.two manual__2025-12-23T12:58:10.561367+00:00
[scheduled]> [airflow.sdk.definitions.dag]
2025-12-23T12:58:23.779720Z [info ] [DAG TEST] end task task_id=two
map_index=-1 [airflow.sdk.definitions.dag]
2025-12-23T12:58:23.791429Z [info ] [DAG TEST] starting task_id=abc
map_index=-1 [airflow.sdk.definitions.dag]
2025-12-23T12:58:23.791658Z [info ] [DAG TEST] running task
<TaskInstance: test_dag.abc manual__2025-12-23T12:58:10.561367+00:00
[scheduled]> [airflow.sdk.definitions.dag]
2025-12-23T12:58:28.362050Z [info ] [DAG TEST] running trigger in line
[airflow.sdk.definitions.dag]
2025-12-23T12:58:28.362373Z [error ] [DAG TEST] Error running task
<TaskInstance: test_dag.abc manual__2025-12-23T12:58:10.561367+00:00 [queued]>
[airflow.sdk.definitions.dag]
Traceback (most recent call last):
File "/opt/airflow/task-sdk/src/airflow/sdk/definitions/dag.py", line
1440, in _run_task
trigger = import_string(msg.classpath)(**msg.trigger_kwargs)
File
"/opt/airflow/providers/standard/src/airflow/providers/standard/triggers/temporal.py",
line 47, in __init__
raise TypeError(f"Expected datetime.datetime type for moment. Got
{type(moment)}")
TypeError: Expected datetime.datetime type for moment. Got <class 'dict'>
2025-12-23T12:58:28.369837Z [info ] [DAG TEST] end task task_id=abc
map_index=-1 [airflow.sdk.definitions.dag]
-------------------------------------------------------------------------------------------
Captured log call
--------------------------------------------------------------------------------------------
INFO airflow.sdk.definitions.dag:dag.py:1404 [DAG TEST] starting
task_id=one map_index=-1
INFO airflow.sdk.definitions.dag:dag.py:1407 [DAG TEST] running task
<TaskInstance: test_dag.one manual__2025-12-23T12:58:10.561367+00:00
[scheduled]>
INFO airflow.sdk.definitions.dag:dag.py:1461 [DAG TEST] end task
task_id=one map_index=-1
INFO airflow.sdk.definitions.dag:dag.py:1404 [DAG TEST] starting
task_id=two map_index=-1
INFO airflow.sdk.definitions.dag:dag.py:1407 [DAG TEST] running task
<TaskInstance: test_dag.two manual__2025-12-23T12:58:10.561367+00:00
[scheduled]>
INFO airflow.sdk.definitions.dag:dag.py:1461 [DAG TEST] end task
task_id=two map_index=-1
INFO airflow.sdk.definitions.dag:dag.py:1404 [DAG TEST] starting
task_id=abc map_index=-1
INFO airflow.sdk.definitions.dag:dag.py:1407 [DAG TEST] running task
<TaskInstance: test_dag.abc manual__2025-12-23T12:58:10.561367+00:00
[scheduled]>
INFO airflow.sdk.definitions.dag:dag.py:1439 [DAG TEST] running trigger
in line
ERROR airflow.sdk.definitions.dag:dag.py:1454 [DAG TEST] Error running
task <TaskInstance: test_dag.abc manual__2025-12-23T12:58:10.561367+00:00
[queued]>
Traceback (most recent call last):
File "/opt/airflow/task-sdk/src/airflow/sdk/definitions/dag.py", line
1440, in _run_task
trigger = import_string(msg.classpath)(**msg.trigger_kwargs)
File
"/opt/airflow/providers/standard/src/airflow/providers/standard/triggers/temporal.py",
line 47, in __init__
raise TypeError(f"Expected datetime.datetime type for moment. Got
{type(moment)}")
TypeError: Expected datetime.datetime type for moment. Got <class 'dict'>
INFO airflow.sdk.definitions.dag:dag.py:1461 [DAG TEST] end task
task_id=abc map_index=-1
```
Or I wouldve missed that the `airflow dags test` fails.
--
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]
