This is an automated email from the ASF dual-hosted git repository.
onikolas pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new f97826dffdf Add more error handling in pod_manager consume_logs
(#55479)
f97826dffdf is described below
commit f97826dffdf619400dd27fef67de5d5b942718d9
Author: Niko Oliveira <[email protected]>
AuthorDate: Thu Sep 11 08:39:07 2025 -0700
Add more error handling in pod_manager consume_logs (#55479)
---
.../airflow/providers/cncf/kubernetes/utils/pod_manager.py | 13 ++++++++++---
1 file changed, 10 insertions(+), 3 deletions(-)
diff --git
a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py
b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py
index a7886b89917..64e606ed4ff 100644
---
a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py
+++
b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py
@@ -521,13 +521,20 @@ class PodManager(LoggingMixin):
# can safely resume from a few seconds later
read_timeout = 60 * 5
try:
+ since_seconds = None
+ if since_time:
+ try:
+ since_seconds = math.ceil((pendulum.now() -
since_time).total_seconds())
+ except TypeError:
+ self.log.warning(
+ "Error calculating since_seconds with since_time
%s. Using None instead.",
+ since_time,
+ )
logs = self.read_pod_logs(
pod=pod,
container_name=container_name,
timestamps=True,
- since_seconds=(
- math.ceil((pendulum.now() -
since_time).total_seconds()) if since_time else None
- ),
+ since_seconds=since_seconds,
follow=follow,
post_termination_timeout=post_termination_timeout,
_request_timeout=(connection_timeout, read_timeout),
