diff --git a/providers/edge3/src/airflow/providers/edge3/cli/worker.py b/providers/edge3/src/airflow/providers/edge3/cli/worker.py index d33462c3b526d..3d4db279a46a2 100644 --- a/providers/edge3/src/airflow/providers/edge3/cli/worker.py +++ b/providers/edge3/src/airflow/providers/edge3/cli/worker.py @@ -188,8 +188,8 @@ def _run_job_via_supervisor( try: api_url = conf.get("edge", "api_url") - execution_api_server_url = conf.get("core", "execution_api_server_url", fallback=...) - if execution_api_server_url is ...: + execution_api_server_url = conf.get("core", "execution_api_server_url", fallback="") + if not execution_api_server_url: parsed = urlparse(api_url) execution_api_server_url = f"{parsed.scheme}://{parsed.netloc}/execution/"