This is an automated email from the ASF dual-hosted git repository.
shahar pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 7594818de51 fix typos in comments within triggerer_job_runner.py
(#58013)
7594818de51 is described below
commit 7594818de51ddddb04794918c981e9e0e66fbd8c
Author: Lê Nam Khánh <[email protected]>
AuthorDate: Fri Nov 7 22:03:53 2025 +0700
fix typos in comments within triggerer_job_runner.py (#58013)
---
airflow-core/src/airflow/jobs/triggerer_job_runner.py | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/airflow-core/src/airflow/jobs/triggerer_job_runner.py
b/airflow-core/src/airflow/jobs/triggerer_job_runner.py
index ddb52618988..cd8b19622d2 100644
--- a/airflow-core/src/airflow/jobs/triggerer_job_runner.py
+++ b/airflow-core/src/airflow/jobs/triggerer_job_runner.py
@@ -414,7 +414,7 @@ class TriggerRunnerSupervisor(WatchedSubprocess):
to_cancel=self.cancelling_triggers,
)
- # Pull out of these deques in a thread-safe manner
+ # Pull out of these dequeues in a thread-safe manner
while self.creating_triggers:
workload = self.creating_triggers.popleft()
response.to_create.append(workload)
@@ -600,7 +600,7 @@ class TriggerRunnerSupervisor(WatchedSubprocess):
Request that we update what triggers we're running.
Works out the differences - ones to add, and ones to remove - then
- adds them to the deques so the subprocess can actually mutate the
running
+ adds them to the dequeues so the subprocess can actually mutate the
running
trigger set.
"""
render_log_fname = log_filename_template_renderer()
@@ -1031,7 +1031,7 @@ class TriggerRunner:
return finished_ids
async def sync_state_to_supervisor(self, finished_ids: list[int]):
- # Copy out of our deques in threadsafe manner to sync state with parent
+ # Copy out of our dequeues in threadsafe manner to sync state with
parent
events_to_send = []
while self.events:
data = self.events.popleft()
