vatsrahul1001 commented on issue #54935:
URL: https://github.com/apache/airflow/issues/54935#issuecomment-3223747168
When I was trying this in main I got below trace
```
[2025-08-26T10:30:04.036+0000] {triggerer_job_runner.py:183} INFO - Exited
trigger loop
Traceback (most recent call last):
File "/usr/local/bin/airflow", line 10, in <module>
sys.exit(main())
File "/opt/airflow/airflow-core/src/airflow/__main__.py", line 55, in main
args.func(args)
File "/opt/airflow/airflow-core/src/airflow/cli/cli_config.py", line 49,
in command
return func(*args, **kwargs)
File "/opt/airflow/airflow-core/src/airflow/utils/cli.py", line 114, in
wrapper
return f(*args, **kwargs)
File
"/opt/airflow/airflow-core/src/airflow/utils/providers_configuration_loader.py",
line 54, in wrapped_function
return func(*args, **kwargs)
File
"/opt/airflow/airflow-core/src/airflow/cli/commands/triggerer_command.py", line
69, in triggerer
run_command_with_daemon_option(
File "/opt/airflow/airflow-core/src/airflow/cli/commands/daemon_utils.py",
line 86, in run_command_with_daemon_option
callback()
File
"/opt/airflow/airflow-core/src/airflow/cli/commands/triggerer_command.py", line
72, in <lambda>
callback=lambda: triggerer_run(args.skip_serve_logs, args.capacity,
triggerer_heartrate),
File
"/opt/airflow/airflow-core/src/airflow/cli/commands/triggerer_command.py", line
55, in triggerer_run
run_job(job=triggerer_job_runner.job,
execute_callable=triggerer_job_runner._execute)
File "/opt/airflow/airflow-core/src/airflow/utils/session.py", line 100,
in wrapper
return func(*args, session=session, **kwargs)
File "/opt/airflow/airflow-core/src/airflow/jobs/job.py", line 368, in
run_job
return execute_job(job, execute_callable=execute_callable)
File "/opt/airflow/airflow-core/src/airflow/jobs/job.py", line 397, in
execute_job
ret = execute_callable()
File "/opt/airflow/airflow-core/src/airflow/jobs/triggerer_job_runner.py",
line 172, in _execute
self.trigger_runner.run()
File "/opt/airflow/airflow-core/src/airflow/jobs/triggerer_job_runner.py",
line 528, in run
self.load_triggers()
File "/opt/airflow/airflow-core/src/airflow/traces/tracer.py", line 58, in
wrapper
return func(*args, **kwargs)
File "/opt/airflow/airflow-core/src/airflow/jobs/triggerer_job_runner.py",
line 551, in load_triggers
self.update_triggers(set(ids))
File "/opt/airflow/airflow-core/src/airflow/jobs/triggerer_job_runner.py",
line 685, in update_triggers
workload = create_workload(new_trigger_orm)
File "/opt/airflow/airflow-core/src/airflow/jobs/triggerer_job_runner.py",
line 626, in create_workload
trigger = expand_start_trigger_args(trigger)
File "/opt/airflow/airflow-core/src/airflow/jobs/triggerer_job_runner.py",
line 612, in expand_start_trigger_args
task =
dag_bag.get_dag(trigger.task_instance.dag_id).get_task(trigger.task_instance.task_id)
AttributeError: 'NoneType' object has no attribute 'get_task'
```
--
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]
