This is an automated email from the ASF dual-hosted git repository.
jscheffl 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 77ee105c602 Fix misleading pod scheduling log message ("Waiting until"
→ "Waiting up to") (#66164)
77ee105c602 is described below
commit 77ee105c60219d3bd58ee7f1492c61fc4b35182e
Author: Stuart Cadman <[email protected]>
AuthorDate: Wed May 13 18:56:02 2026 +0100
Fix misleading pod scheduling log message ("Waiting until" → "Waiting up
to") (#66164)
* update pod scheduling log message to 'Waiting up to'
* Update unit tests with new log text
---------
Co-authored-by: Jed Cunningham
<[email protected]>
---
.../src/airflow/providers/cncf/kubernetes/utils/pod_manager.py | 2 +-
.../cncf/kubernetes/tests/unit/cncf/kubernetes/triggers/test_pod.py | 2 +-
.../kubernetes/tests/unit/cncf/kubernetes/utils/test_pod_manager.py | 4 ++--
.../google/tests/unit/google/cloud/triggers/test_kubernetes_engine.py | 2 +-
4 files changed, 5 insertions(+), 5 deletions(-)
diff --git
a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py
b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py
index 9b75ba807f2..e4bb7ae9115 100644
---
a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py
+++
b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py
@@ -164,7 +164,7 @@ async def await_pod_start(
:param check_interval: Interval (in seconds) between status checks.
:param is_async: Set to True if called in an async context; otherwise,
False.
"""
- pod_manager.log.info("::group::Waiting until %ss to get the POD
scheduled...", schedule_timeout)
+ pod_manager.log.info("::group::Waiting up to %ss to get the POD
scheduled...", schedule_timeout)
pod_was_scheduled = False
start_check_time = time.time()
is_async = isinstance(pod_manager, AsyncPodManager)
diff --git
a/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/triggers/test_pod.py
b/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/triggers/test_pod.py
index cc35bd4db47..26b2db90e16 100644
--- a/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/triggers/test_pod.py
+++ b/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/triggers/test_pod.py
@@ -302,7 +302,7 @@ class TestKubernetesPodTrigger:
generator = trigger.run()
await generator.asend(None)
- assert "Waiting until 120s to get the POD scheduled..." in caplog.text
+ assert "Waiting up to 120s to get the POD scheduled..." in caplog.text
@pytest.mark.asyncio
@pytest.mark.parametrize(
diff --git
a/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/utils/test_pod_manager.py
b/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/utils/test_pod_manager.py
index 4b9a9097041..27cfd87fc6d 100644
---
a/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/utils/test_pod_manager.py
+++
b/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/utils/test_pod_manager.py
@@ -971,7 +971,7 @@ class TestPodManager:
assert self.pod_manager.stop_watching_events is True
assert mock_time_sleep.call_count == 3
mock_log_info.assert_any_call(
- "::group::Waiting until %ss to get the POD scheduled...",
schedule_timeout
+ "::group::Waiting up to %ss to get the POD scheduled...",
schedule_timeout
)
mock_log_info.assert_any_call("Waiting %ss to get the POD
running...", startup_timeout)
@@ -1594,7 +1594,7 @@ class TestAsyncPodManager:
)
assert mock_time_sleep.call_count == 3
mock_log_info.assert_any_call(
- "::group::Waiting until %ss to get the POD scheduled...",
schedule_timeout
+ "::group::Waiting up to %ss to get the POD scheduled...",
schedule_timeout
)
mock_log_info.assert_any_call("Waiting %ss to get the POD running...",
startup_timeout)
assert self.async_pod_manager.stop_watching_events is True
diff --git
a/providers/google/tests/unit/google/cloud/triggers/test_kubernetes_engine.py
b/providers/google/tests/unit/google/cloud/triggers/test_kubernetes_engine.py
index 2d96ab43eac..34cb30740a9 100644
---
a/providers/google/tests/unit/google/cloud/triggers/test_kubernetes_engine.py
+++
b/providers/google/tests/unit/google/cloud/triggers/test_kubernetes_engine.py
@@ -270,7 +270,7 @@ class TestGKEStartPodTrigger:
generator = trigger.run()
await generator.asend(None)
- assert "Waiting until 60s to get the POD scheduled..." in caplog.text
+ assert "Waiting up to 60s to get the POD scheduled..." in caplog.text
@pytest.mark.parametrize(
("container_state", "expected_state"),
