This is an automated email from the ASF dual-hosted git repository.
pankajkoti 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 84f1ae23cc Add missing informative logs in KPO trigger until container
has not finished (#37546)
84f1ae23cc is described below
commit 84f1ae23cc817c4e1e8066702938aeccc0a0d826
Author: Pankaj Koti <[email protected]>
AuthorDate: Wed Apr 24 12:55:07 2024 +0530
Add missing informative logs in KPO trigger until container has not
finished (#37546)
* Add informative logs in KPO trigger until container has not finished
---
airflow/providers/cncf/kubernetes/triggers/pod.py | 2 ++
1 file changed, 2 insertions(+)
diff --git a/airflow/providers/cncf/kubernetes/triggers/pod.py
b/airflow/providers/cncf/kubernetes/triggers/pod.py
index b88c2851c7..b74e3ef877 100644
--- a/airflow/providers/cncf/kubernetes/triggers/pod.py
+++ b/airflow/providers/cncf/kubernetes/triggers/pod.py
@@ -262,6 +262,7 @@ class KubernetesPodTrigger(BaseTrigger):
"last_log_time": self.last_log_time,
}
)
+ self.log.debug("Container is not completed and still working.")
if time_get_more_logs and
datetime.datetime.now(tz=datetime.timezone.utc) > time_get_more_logs:
return TriggerEvent(
{
@@ -271,6 +272,7 @@ class KubernetesPodTrigger(BaseTrigger):
"name": self.pod_name,
}
)
+ self.log.debug("Sleeping for %s seconds.", self.poll_interval)
await asyncio.sleep(self.poll_interval)
def _get_async_hook(self) -> AsyncKubernetesHook:
