This is an automated email from the ASF dual-hosted git repository. mobuchowski pushed a commit to branch notify-exception-caught in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 0e81e140899e42f010049c912febdde93c178f62 Author: Maciej Obuchowski <[email protected]> AuthorDate: Wed May 8 15:40:06 2024 +0200 openlineage: notify that logged exception was caught Signed-off-by: Maciej Obuchowski <[email protected]> --- airflow/providers/openlineage/utils/utils.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/airflow/providers/openlineage/utils/utils.py b/airflow/providers/openlineage/utils/utils.py index ad1f3b0951..b9cd385cc5 100644 --- a/airflow/providers/openlineage/utils/utils.py +++ b/airflow/providers/openlineage/utils/utils.py @@ -367,6 +367,9 @@ def print_warning(log): try: return f(*args, **kwargs) except Exception as e: + log.warning( + "Note: exception below is being caught: it's printed for visibility. However OpenLineage events aren't being emitted. If you see that, task has completed successfully despite not getting OL events." + ) log.warning(e) return wrapper
