fix: use instance base_container_name to fetch logs on trigger_reentry

apache · Jul 17, 2024 · ada3b9a · ada3b9a
1 parent 6366204
commit ada3b9a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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,
                     )