diff --git a/airflow/jobs/triggerer_job_runner.py b/airflow/jobs/triggerer_job_runner.py index 610441be21213..ccc4508ff9ede 100644 --- a/airflow/jobs/triggerer_job_runner.py +++ b/airflow/jobs/triggerer_job_runner.py @@ -607,12 +607,11 @@ async def run_trigger(self, trigger_id, trigger): self.log.info("Trigger %s fired: %s", self.triggers[trigger_id]["name"], event) self.triggers[trigger_id]["events"] += 1 self.events.append((trigger_id, event)) - except asyncio.CancelledError as err: + except asyncio.CancelledError: if timeout := trigger.task_instance.trigger_timeout: timeout = timeout.replace(tzinfo=timezone.utc) if not timeout.tzinfo else timeout if timeout < timezone.utcnow(): self.log.error("Trigger cancelled due to timeout") - self.log.error("Trigger cancelled; message=%s", err) raise finally: # CancelledError will get injected when we're stopped - which is