Skip to content

Commit

Permalink
Add cancel_trigger_ids to to_cancel dequeue in batch (#33944)
Browse files Browse the repository at this point in the history
(cherry picked from commit f63a94d)
  • Loading branch information
hussein-awala authored and ephraimbuddy committed Oct 5, 2023
1 parent b166606 commit 53c99eb
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions airflow/jobs/triggerer_job_runner.py
Original file line number Diff line number Diff line change
Expand Up @@ -680,8 +680,7 @@ def update_triggers(self, requested_trigger_ids: set[int]):
self.set_trigger_logging_metadata(new_trigger_orm.task_instance, new_id, new_trigger_instance)
self.to_create.append((new_id, new_trigger_instance))
# Enqueue orphaned triggers for cancellation
for old_id in cancel_trigger_ids:
self.to_cancel.append(old_id)
self.to_cancel.extend(cancel_trigger_ids)

def set_trigger_logging_metadata(self, ti: TaskInstance, trigger_id, trigger):
"""
Expand Down

0 comments on commit 53c99eb

Please sign in to comment.