diff --git a/airflow/providers/cncf/kubernetes/utils/pod_manager.py b/airflow/providers/cncf/kubernetes/utils/pod_manager.py index 3b3a7b7a9eb..f84a044d68c 100644 --- a/airflow/providers/cncf/kubernetes/utils/pod_manager.py +++ b/airflow/providers/cncf/kubernetes/utils/pod_manager.py @@ -214,9 +214,14 @@ def consume_logs(*, since_time: Optional[DateTime] = None, follow: bool = True) for line in logs: timestamp, message = self.parse_log_line(line.decode('utf-8')) self.log.info(message) - except BaseHTTPError: # Catches errors like ProtocolError(TimeoutError). + except BaseHTTPError as e: self.log.warning( - 'Failed to read logs for pod %s', + "Reading of logs interrupted with error %r; will retry. " + "Set log level to DEBUG for traceback.", + e, + ) + self.log.debug( + "Traceback for interrupted logs read for pod %r", pod.metadata.name, exc_info=True, )