diff --git a/airflow/providers/cncf/kubernetes/triggers/pod.py b/airflow/providers/cncf/kubernetes/triggers/pod.py index b88c2851c7175..b74e3ef877b1d 100644 --- a/airflow/providers/cncf/kubernetes/triggers/pod.py +++ b/airflow/providers/cncf/kubernetes/triggers/pod.py @@ -262,6 +262,7 @@ async def _wait_for_container_completion(self) -> TriggerEvent: "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 @@ async def _wait_for_container_completion(self) -> TriggerEvent: "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: