From 3df3f30e930b02cc75ae098bf115c75bb827a9ea Mon Sep 17 00:00:00 2001 From: Kaxil Naik Date: Thu, 29 May 2025 04:30:28 +0530 Subject: [PATCH] Fix execution API server URL handling for relative paths in KE Follow-up of https://github.com/apache/airflow/pull/49782 but for KubernetesExecutor. --- task-sdk/src/airflow/sdk/execution_time/execute_workload.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/task-sdk/src/airflow/sdk/execution_time/execute_workload.py b/task-sdk/src/airflow/sdk/execution_time/execute_workload.py index 220cd65c5ec9c..b06a0d22cb4e4 100644 --- a/task-sdk/src/airflow/sdk/execution_time/execute_workload.py +++ b/task-sdk/src/airflow/sdk/execution_time/execute_workload.py @@ -56,6 +56,9 @@ def execute_workload(workload: ExecuteTask) -> None: log.info("Executing workload", workload=workload) base_url = conf.get("api", "base_url", fallback="/") + # If it's a relative URL, use localhost:8080 as the default + if base_url.startswith("/"): + base_url = f"http://localhost:8080{base_url}" default_execution_api_server = f"{base_url.rstrip('/')}/execution/" server = conf.get("core", "execution_api_server_url", fallback=default_execution_api_server) log.info("Connecting to server:", server=server)