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
  • Loading branch information
hussein-awala authored Aug 31, 2023
1 parent ba26192 commit f63a94d
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 @@ -687,8 +687,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 f63a94d

Please sign in to comment.