From ada3b9a2c7f3fbf0725e96861fa67a72417b0ef2 Mon Sep 17 00:00:00 2001 From: Jean-Eudes Peloye Date: Wed, 17 Jul 2024 14:16:06 +0200 Subject: [PATCH] fix: use instance base_container_name to fetch logs on trigger_reentry --- airflow/providers/cncf/kubernetes/operators/pod.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/providers/cncf/kubernetes/operators/pod.py b/airflow/providers/cncf/kubernetes/operators/pod.py index 8df4137a288fd..60508dfd862b1 100644 --- a/airflow/providers/cncf/kubernetes/operators/pod.py +++ b/airflow/providers/cncf/kubernetes/operators/pod.py @@ -766,7 +766,7 @@ def trigger_reentry(self, context: Context, event: dict[str, Any]) -> Any: pod_log_status = self.pod_manager.fetch_container_logs( pod=self.pod, - container_name=self.BASE_CONTAINER_NAME, + container_name=self.base_container_name, follow=follow, since_time=last_log_time, )