This is an automated email from the ASF dual-hosted git repository. jedcunningham pushed a commit to branch v2-4-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 92eaa09d1ff316e4715fb8ca0fffee467d8c8f65 Author: Jarek Potiuk <[email protected]> AuthorDate: Mon Sep 19 18:37:48 2022 +0200 Fix proper joining of the path for logs retrieved from celery workers (#26493) The change #26377 "fixed" the way how logs were retrieved from Celery, but it - unfortunately broke the retrieval eventually. This PR should fix it. Fixes: #26492 (cherry picked from commit 52560b87c991c9739791ca8419219b0d86debacd) --- airflow/utils/log/file_task_handler.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/airflow/utils/log/file_task_handler.py b/airflow/utils/log/file_task_handler.py index f87df22f66..b7ee88ef76 100644 --- a/airflow/utils/log/file_task_handler.py +++ b/airflow/utils/log/file_task_handler.py @@ -198,7 +198,8 @@ class FileTaskHandler(logging.Handler): 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"
