JH0917 commented on code in PR #68792:
URL: https://github.com/apache/airflow/pull/68792#discussion_r3698264812
##########
airflow-core/src/airflow/jobs/triggerer_job_runner.py:
##########
@@ -1399,11 +1417,14 @@ def process_trigger_events(self, finished_ids:
list[int]) -> messages.TriggerSta
trigger_id, exc = self.failed_triggers.popleft()
tb = format_exception(type(exc), exc, exc.__traceback__) if exc
else None
failures_to_send.append((trigger_id, tb))
+ if trigger_id not in self.triggers:
+ finished_ids.append(trigger_id)
Review Comment:
Fixed -- builds a local list now, parameter is untouched, added regression
test too. Thanks for pointing that out.
--
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]
