seanghaeli opened a new issue, #77053: URL: https://github.com/apache/airflow/issues/77053
When a trigger raises after it has fired at least one event, `cleanup_finished_triggers` (`airflow-core/src/airflow/jobs/triggerer_job_runner.py`) only logs the exception: it reports a failure only when the trigger fired nothing (`if details["events"] == 0`). For a deferred task that's fine, since the event already resumed it. But an asset watcher is re-created right away, and its row's failure count, status and last error never change, so a watcher that fires once and then crashes every time looks healthy in the API and UI. Done when: a watcher that raises after firing an event is recorded as a failure (`Trigger.submit_failure`), the same way as one that raises before, while a deferred task's trigger still isn't, with a test for both cases. This is small and self-contained, so it would make a good first issue. -- 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]
