diff --git a/airflow/utils/log/file_task_handler.py b/airflow/utils/log/file_task_handler.py index cd4d049d9aa70..74d4d1b08dc54 100644 --- a/airflow/utils/log/file_task_handler.py +++ b/airflow/utils/log/file_task_handler.py @@ -212,7 +212,8 @@ def _read(self, ti: TaskInstance, try_number: int, metadata: dict[str, Any] | No import httpx url = urljoin( - f"http://{ti.hostname}:{conf.get('logging', 'WORKER_LOG_SERVER_PORT')}/log", log_relative_path + f"http://{ti.hostname}:{conf.get('logging', 'WORKER_LOG_SERVER_PORT')}/log/", + log_relative_path, ) log += f"*** Log file does not exist: {location}\n" log += f"*** Fetching from: {url}\n"