Airflow 3.1 dag procesor typo in function name

[fenix7]

Apache Airflow version

3.1.0

If "Other Airflow 2 version" selected, which one?

No response

What happened?

ag-processor | 2025-09-29T09:31:51.190294Z [info     ] Setting next_dagrun for example_weekday_branch_operator to 2025-09-29 00:00:00+00:00, run_after=2025-09-29 00:00:00+00:00 [airflow.models.dag] loc=dag.py:688
dag-processor | 2025-09-29T09:31:51.214129Z [error    ] Exception when executing DagProcessorJob [airflow.jobs.dag_processor_job_runner.DagProcessorJobRunner] loc=dag_processor_job_runner.py:63
dag-processor | Traceback (most recent call last):
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/jobs/dag_processor_job_runner.py", line 61, in _execute
dag-processor | self.processor.run()
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/dag_processing/manager.py", line 272, in run
dag-processor | return self._run_parsing_loop()
dag-processor | ^^^^^^^^^^^^^^^^^^^^^^^^
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/dag_processing/manager.py", line 357, in _run_parsing_loop
dag-processor | self._start_new_processes()
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/dag_processing/manager.py", line 924, in _start_new_processes
dag-processor | processor = self._create_process(file)
dag-processor | ^^^^^^^^^^^^^^^^^^^^^^^^^^
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/dag_processing/manager.py", line 905, in _create_process
dag-processor | return DagFileProcessorProcess.start(
dag-processor | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/dag_processing/processor.py", line 459, in start
dag-processor | _pre_import_airflow_modules(os.fspath(path), logger)
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/dag_processing/processor.py", line 158, in _pre_import_airflow_modules
dag-processor | importlib.import_module(module)
dag-processor | File "/usr/lib/python3.12/importlib/__init__.py", line 90, in import_module
dag-processor | return _bootstrap._gcd_import(name[level:], package, level)
dag-processor | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
dag-processor | File "<frozen importlib._bootstrap>", line 1387, in _gcd_import
dag-processor | File "<frozen importlib._bootstrap>", line 1360, in _find_and_load
dag-processor | File "<frozen importlib._bootstrap>", line 1331, in _find_and_load_unlocked
dag-processor | File "<frozen importlib._bootstrap>", line 935, in _load_unlocked

(.venv) mkutwin@cas-ai:~$ dag-processor | File "<frozen importlib._bootstrap_external>", line 995, in exec_module
dag-processor | File "<frozen importlib._bootstrap>", line 488, in _call_with_frames_removed
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/providers/standard/operators/hitl.py", line 33, in <module>
dag-processor | from airflow.providers.standard.triggers.hitl import HITLTrigger, HITLTriggerEventSuccessPayload
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/providers/standard/triggers/hitl.py", line 33, in <module>
dag-processor | from airflow.sdk.execution_time.hitl import (
dag-processor | ImportError: cannot import name 'update_htil_detail_response' from 'airflow.sdk.execution_time.hitl' (/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/sdk/execution_time/hitl.py)
dag-processor | 2025-09-29T09:31:51.226315Z [info     ] Process exited                 [supervisor] exit_code=<Negsignal.SIGTERM: -15> loc=supervisor.py:709 pid=6868 signal_sent=SIGTERM
dag-processor | 2025-09-29T09:31:51.234770Z [info     ] Waiting up to 5 seconds for processes to exit... [airflow.utils.process_utils] loc=process_utils.py:285
dag-processor | Traceback (most recent call last):
dag-processor | File "/home/mkutwin/.venv/bin/airflow", line 8, in <module>
dag-processor | sys.exit(main())
dag-processor | ^^^^^^
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/__main__.py", line 55, in main
dag-processor | args.func(args)
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/cli/cli_config.py", line 49, in command
dag-processor | return func(*args, **kwargs)
dag-processor | ^^^^^^^^^^^^^^^^^^^^^
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/utils/cli.py", line 114, in wrapper
dag-processor | return f(*args, **kwargs)
dag-processor | ^^^^^^^^^^^^^^^^^^
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/utils/providers_configuration_loader.py", line 54, in wrapped_function
dag-processor | return func(*args, **kwargs)
dag-processor | ^^^^^^^^^^^^^^^^^^^^^
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/cli/commands/dag_processor_command.py", line 53, in dag_processor
dag-processor | run_command_with_daemon_option(
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/cli/commands/daemon_utils.py", line 86, in run_command_with_daemon_option
dag-processor | callback()
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/cli/commands/dag_processor_command.py", line 56, in <lambda>
dag-processor | callback=lambda: run_job(job=job_runner.job, execute_callable=job_runner._execute),
dag-processor | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/utils/session.py", line 100, in wrapper
dag-processor | return func(*args, session=session, **kwargs)
dag-processor | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/jobs/job.py", line 368, in run_job
dag-processor | return execute_job(job, execute_callable=execute_callable)
dag-processor | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/jobs/job.py", line 397, in execute_job
dag-processor | ret = execute_callable()
dag-processor | ^^^^^^^^^^^^^^^^^^
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/jobs/dag_processor_job_runner.py", line 61, in _execute
dag-processor | self.processor.run()
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/dag_processing/manager.py", line 272, in run
dag-processor | return self._run_parsing_loop()
dag-processor | ^^^^^^^^^^^^^^^^^^^^^^^^
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/dag_processing/manager.py", line 357, in _run_parsing_loop
dag-processor | self._start_new_processes()
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/dag_processing/manager.py", line 924, in _start_new_processes
dag-processor | processor = self._create_process(file)
dag-processor | ^^^^^^^^^^^^^^^^^^^^^^^^^^
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/dag_processing/manager.py", line 905, in _create_process
dag-processor | return DagFileProcessorProcess.start(
dag-processor | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/dag_processing/processor.py", line 459, in start
dag-processor | _pre_import_airflow_modules(os.fspath(path), logger)
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/dag_processing/processor.py", line 158, in _pre_import_airflow_modules
dag-processor | importlib.import_module(module)
dag-processor | File "/usr/lib/python3.12/importlib/__init__.py", line 90, in import_module
dag-processor | return _bootstrap._gcd_import(name[level:], package, level)
dag-processor | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
dag-processor | File "<frozen importlib._bootstrap>", line 1387, in _gcd_import
dag-processor | File "<frozen importlib._bootstrap>", line 1360, in _find_and_load
dag-processor | File "<frozen importlib._bootstrap>", line 1331, in _find_and_load_unlocked
dag-processor | File "<frozen importlib._bootstrap>", line 935, in _load_unlocked
dag-processor | File "<frozen importlib._bootstrap_external>", line 995, in exec_module
dag-processor | File "<frozen importlib._bootstrap>", line 488, in _call_with_frames_removed
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/providers/standard/operators/hitl.py", line 33, in <module>
dag-processor | from airflow.providers.standard.triggers.hitl import HITLTrigger, HITLTriggerEventSuccessPayload
dag-processor | File "/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/providers/standard/triggers/hitl.py", line 33, in <module>
dag-processor | from airflow.sdk.execution_time.hitl import (
dag-processor | ImportError: cannot import name 'update_htil_detail_response' from 'airflow.sdk.execution_time.hitl' (/home/mkutwin/.venv/lib/python3.12/site-packages/airflow/sdk/execution_time/hitl.py). Did you mean: 'update_hitl_detail_response'?

What you think should happen instead?

No response

How to reproduce

upgrade airflow

Operating System

ubuntu 24.02

Versions of Apache Airflow Providers

No response

Deployment

Official Apache Airflow Helm Chart

Deployment details

No response

Anything else?

No response

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[boring-cyborg]

Thanks for opening your first issue here! Be sure to follow the issue template! If you are willing to raise PR to address this issue please do so, no need to wait for approval.

[amoghrajesh]

cc @Lee-W / @vatsrahul1001 have we seen this kind of issue before?

[Lee-W]

This is kinda expected. We need to upgrade standard provider version. I think 1.8.0 would work

[fenix7]

but which provider

[Lee-W]

https://airflow.apache.org/docs/apache-airflow-providers-standard/stable/index.html

[eladkal]

@Lee-W I already bumped min version of providers in core #56208
is there something else needed?

[Lee-W]

yep, i think that's all we need.