This is an automated email from the ASF dual-hosted git repository.
rahulvats pushed a commit to branch v3-2-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-2-test by this push:
new 93d20d75a7a [v3-2-test] Lock TriggerCommsDecoder sync req-res cycle
(#64882) (#65285)
93d20d75a7a is described below
commit 93d20d75a7a932d1593bfe20caa5b5c342ab4219
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Apr 15 13:28:23 2026 +0530
[v3-2-test] Lock TriggerCommsDecoder sync req-res cycle (#64882) (#65285)
(cherry picked from commit f102ad7f663d0e253f6f917c13326bf417c7c8c1)
Co-authored-by: Tzu-ping Chung <[email protected]>
---
airflow-core/src/airflow/jobs/triggerer_job_runner.py | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/airflow-core/src/airflow/jobs/triggerer_job_runner.py
b/airflow-core/src/airflow/jobs/triggerer_job_runner.py
index 44c28a7a539..4cfe262b71e 100644
--- a/airflow-core/src/airflow/jobs/triggerer_job_runner.py
+++ b/airflow-core/src/airflow/jobs/triggerer_job_runner.py
@@ -821,12 +821,14 @@ class TriggerCommsDecoder(CommsDecoder[ToTriggerRunner,
ToTriggerSupervisor]):
def _read_frame(self):
from asgiref.sync import async_to_sync
- return async_to_sync(self._aread_frame)()
+ with self._thread_lock:
+ return async_to_sync(self._aread_frame)()
def send(self, msg: ToTriggerSupervisor) -> ToTriggerRunner | None:
from asgiref.sync import async_to_sync
- return async_to_sync(self.asend)(msg)
+ with self._thread_lock:
+ return async_to_sync(self.asend)(msg)
async def _aread_frame(self):
try:
