mobuchowski commented on PR #48427: URL: https://github.com/apache/airflow/pull/48427#issuecomment-2757217077
@dstandish all dagrun-level OL listeners wrap everything they do in try: except BaseException - https://github.com/apache/airflow/blob/2b082e670a9689edfd734cd8b3296d62170c62ed/providers/openlineage/src/airflow/providers/openlineage/plugins/listener.py#L521 The error happens in separate process that itself is guarded inside by try: except BaseException: https://github.com/apache/airflow/blob/807bdca29c634a04be85637902db680f567f8e73/providers/openlineage/src/airflow/providers/openlineage/plugins/adapter.py#L376 I feel like the real question is how this happened `psycopg2.OperationalError: lost synchronization with server: got message type "r", length 1919509605` and whether it's actually responsible for task failing (with some other, missing log piece?). -- 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]
