You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by am...@apache.org on 2025/10/28 07:10:02 UTC
(airflow) branch main updated: Log execution API server URL at task startup (#57343)
This is an automated email from the ASF dual-hosted git repository.
amoghdesai 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 cd32d1b29dc Log execution API server URL at task startup (#57343)
cd32d1b29dc is described below
commit cd32d1b29dca31b2c3a385ff1c8a376c9a28f368
Author: Amogh Desai <am...@gmail.com>
AuthorDate: Tue Oct 28 12:39:55 2025 +0530
Log execution API server URL at task startup (#57343)
---
task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1 +
1 file changed, 1 insertion(+)
diff --git a/task-sdk/src/airflow/sdk/execution_time/supervisor.py b/task-sdk/src/airflow/sdk/execution_time/supervisor.py
index 493644d5080..73dbc448fb2 100644
--- a/task-sdk/src/airflow/sdk/execution_time/supervisor.py
+++ b/task-sdk/src/airflow/sdk/execution_time/supervisor.py
@@ -1930,6 +1930,7 @@ def supervise(
limits = httpx.Limits(max_keepalive_connections=1, max_connections=10)
client = Client(base_url=server or "", limits=limits, dry_run=dry_run, token=token)
close_client = True
+ log.debug("Connecting to execution API server", server=server)
start = time.monotonic()