We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3953231 commit 3df3f30Copy full SHA for 3df3f30
task-sdk/src/airflow/sdk/execution_time/execute_workload.py
@@ -56,6 +56,9 @@ def execute_workload(workload: ExecuteTask) -> None:
56
log.info("Executing workload", workload=workload)
57
58
base_url = conf.get("api", "base_url", fallback="/")
59
+ # If it's a relative URL, use localhost:8080 as the default
60
+ if base_url.startswith("/"):
61
+ base_url = f"http://localhost:8080{base_url}"
62
default_execution_api_server = f"{base_url.rstrip('/')}/execution/"
63
server = conf.get("core", "execution_api_server_url", fallback=default_execution_api_server)
64
log.info("Connecting to server:", server=server)
0 commit comments