This is an automated email from the ASF dual-hosted git repository.
jedcunningham pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 52560b87c9 Fix proper joining of the path for logs retrieved from
celery workers (#26493)
52560b87c9 is described below
commit 52560b87c991c9739791ca8419219b0d86debacd
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
---
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 cd4d049d9a..74d4d1b08d 100644
--- a/airflow/utils/log/file_task_handler.py
+++ b/airflow/utils/log/file_task_handler.py
@@ -212,7 +212,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"
