jason810496 opened a new issue, #64613:
URL: https://github.com/apache/airflow/issues/64613
### Apache Airflow version
Latest 3-2-test branch, commit hash: e64b7e41d72e5bad9ff7d90b8d10797f0a9a0756
### What happened and how to reproduce it?
Dag-Processor Logs
```python
2026-04-02T03:34:27.353773Z [info ] Process exited
[supervisor] exit_code=0 loc=supervisor.py:740 pid=2024 signal_sent=SIGTERM
2026-04-02T03:34:27.358180Z [info ] Waiting up to 5 seconds for
processes to exit... [airflow.utils.process_utils] loc=process_utils.py:308
Traceback (most recent call last):
File "/usr/python/lib/python3.10/site-packages/airflow/models/trigger.py",
line 172, in _decrypt_kwargs
result = deserialize(decrypted_kwargs)
File
"/usr/python/lib/python3.10/site-packages/airflow/sdk/serde/__init__.py", line
240, in deserialize
return {str(k): deserialize(v, full) for k, v in o.items()}
File
"/usr/python/lib/python3.10/site-packages/airflow/sdk/serde/__init__.py", line
240, in <dictcomp>
return {str(k): deserialize(v, full) for k, v in o.items()}
File
"/usr/python/lib/python3.10/site-packages/airflow/sdk/serde/__init__.py", line
264, in deserialize
raise ImportError(
ImportError: tuple was not found in allow list for deserialization imports.
To allow it, add it to allowed_deserialization_classes in the configuration
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/python/bin/airflow", line 10, in <module>
sys.exit(main())
File "/usr/python/lib/python3.10/site-packages/airflow/__main__.py", line
55, in main
args.func(args)
File "/usr/python/lib/python3.10/site-packages/airflow/cli/cli_config.py",
line 49, in command
return func(*args, **kwargs)
File
"/usr/python/lib/python3.10/site-packages/airflow/utils/memray_utils.py", line
59, in wrapper
return func(*args, **kwargs)
File "/usr/python/lib/python3.10/site-packages/airflow/utils/cli.py", line
113, in wrapper
return f(*args, **kwargs)
File
"/usr/python/lib/python3.10/site-packages/airflow/utils/providers_configuration_loader.py",
line 54, in wrapped_function
return func(*args, **kwargs)
File
"/usr/python/lib/python3.10/site-packages/airflow/cli/commands/dag_processor_command.py",
line 64, in dag_processor
run_command_with_daemon_option(
File
"/usr/python/lib/python3.10/site-packages/airflow/cli/commands/daemon_utils.py",
line 86, in run_command_with_daemon_option
callback()
File
"/usr/python/lib/python3.10/site-packages/airflow/cli/commands/dag_processor_command.py",
line 67, in <lambda>
callback=lambda: run_job(job=job_runner.job,
execute_callable=job_runner._execute),
File "/usr/python/lib/python3.10/site-packages/airflow/utils/session.py",
line 100, in wrapper
return func(*args, session=session, **kwargs) # type: ignore[arg-type]
File "/usr/python/lib/python3.10/site-packages/airflow/jobs/job.py", line
355, in run_job
return execute_job(job, execute_callable=execute_callable)
File "/usr/python/lib/python3.10/site-packages/airflow/jobs/job.py", line
384, in execute_job
ret = execute_callable()
File
"/usr/python/lib/python3.10/site-packages/airflow/jobs/dag_processor_job_runner.py",
line 61, in _execute
self.processor.run()
File
"/usr/python/lib/python3.10/site-packages/airflow/dag_processing/manager.py",
line 334, in run
return self._run_parsing_loop()
File
"/usr/python/lib/python3.10/site-packages/airflow/dag_processing/manager.py",
line 441, in _run_parsing_loop
self._collect_results()
File "/usr/python/lib/python3.10/site-packages/airflow/utils/session.py",
line 100, in wrapper
return func(*args, session=session, **kwargs) # type: ignore[arg-type]
File
"/usr/python/lib/python3.10/site-packages/airflow/dag_processing/manager.py",
line 948, in _collect_results
self._file_stats[file] = process_parse_results(
File
"/usr/python/lib/python3.10/site-packages/airflow/dag_processing/manager.py",
line 1347, in process_parse_results
update_dag_parsing_results_in_db(
File
"/usr/python/lib/python3.10/site-packages/airflow/dag_processing/collection.py",
line 463, in update_dag_parsing_results_in_db
for attempt in run_with_db_retries(logger=log):
File "/usr/python/lib/python3.10/site-packages/tenacity/__init__.py", line
438, in __iter__
do = self.iter(retry_state=retry_state)
File "/usr/python/lib/python3.10/site-packages/tenacity/__init__.py", line
371, in iter
result = action(retry_state)
File "/usr/python/lib/python3.10/site-packages/tenacity/__init__.py", line
393, in <lambda>
self._add_action_func(lambda rs: rs.outcome.result())
File "/usr/python/lib/python3.10/concurrent/futures/_base.py", line 451,
in result
return self.__get_result()
File "/usr/python/lib/python3.10/concurrent/futures/_base.py", line 403,
in __get_result
raise self._exception
File
"/usr/python/lib/python3.10/site-packages/airflow/dag_processing/collection.py",
line 473, in update_dag_parsing_results_in_db
SerializedDAG.bulk_write_to_db(
File "/usr/python/lib/python3.10/site-packages/airflow/utils/session.py",
line 98, in wrapper
return func(*args, **kwargs)
File
"/usr/python/lib/python3.10/site-packages/airflow/serialization/definitions/dag.py",
line 221, in bulk_write_to_db
asset_op.add_asset_trigger_references(orm_assets, session=session)
File
"/usr/python/lib/python3.10/site-packages/airflow/dag_processing/collection.py",
line 1082, in add_asset_trigger_references
orm_triggers.update(
File
"/usr/python/lib/python3.10/site-packages/airflow/dag_processing/collection.py",
line 1083, in <genexpr>
(BaseEventTrigger.hash(trigger.classpath, trigger.kwargs), trigger)
File "/usr/python/lib/python3.10/site-packages/airflow/models/trigger.py",
line 135, in kwargs
return self._decrypt_kwargs(self.encrypted_kwargs)
File "/usr/python/lib/python3.10/site-packages/airflow/models/trigger.py",
line 180, in _decrypt_kwargs
return BaseSerialization.deserialize(decrypted_kwargs)
File
"/usr/python/lib/python3.10/site-packages/airflow/serialization/serialized_objects.py",
line 629, in deserialize
var = encoded_var[Encoding.VAR]
KeyError: <Encoding.VAR: '__var'>
```
### What you think should happen instead?
_No response_
### Operating System
Breeze
### Versions of Apache Airflow Providers
_No response_
### Deployment
None
### 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
- [x] I agree to follow this project's [Code of
Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
--
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]
