Added container logs default

LamaAni · Apr 27, 2021 · bc52a09 · bc52a09
1 parent ad9aa08
commit bc52a09
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/airflow_kubernetes_job_operator/kube_api/queries.py b/airflow_kubernetes_job_operator/kube_api/queries.py
@@ -91,7 +91,7 @@ def __init__(
         follow: bool = False,
         timeout: int = None,
         container: str = None,
-        add_container_name_to_log: bool = False,
+        add_container_name_to_log: bool = None,
     ):
         """Returns the pod logs for a pod. Can follow the pod logs
         in real time.
@@ -134,7 +134,9 @@ def __init__(
         self.since = since
         self._last_timestamp = None
         self._active_namespace = None
-        self.add_container_name_to_log = add_container_name_to_log
+        self.add_container_name_to_log = (
+            add_container_name_to_log if add_container_name_to_log is not None else container is not None
+        )
 
     def pre_request(self, client: "KubeApiRestClient"):
         super().pre_request(client)