This is an automated email from the ASF dual-hosted git repository.
jasonliu 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 726d4b5c5b5 Fix WASB remote logging base path handling (#58946)
(#61013)
726d4b5c5b5 is described below
commit 726d4b5c5b59e1be82708f56102b4ced52078c40
Author: Aaron Chen <[email protected]>
AuthorDate: Tue Feb 24 23:17:08 2026 -0800
Fix WASB remote logging base path handling (#58946) (#61013)
* Fix WASB remote logging base path handling
* Fix WASB remote logging base path handling by simplifying prefix removal
* Clarify handling of WASB remote logging base path format in comments
* fix CI static checks error
---
airflow-core/src/airflow/config_templates/airflow_local_settings.py | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git
a/airflow-core/src/airflow/config_templates/airflow_local_settings.py
b/airflow-core/src/airflow/config_templates/airflow_local_settings.py
index 4deb996de08..e0f94c77b2d 100644
--- a/airflow-core/src/airflow/config_templates/airflow_local_settings.py
+++ b/airflow-core/src/airflow/config_templates/airflow_local_settings.py
@@ -220,11 +220,14 @@ if REMOTE_LOGGING:
"azure_remote_logging", "remote_wasb_log_container",
fallback="airflow-logs"
)
+ # Handle both URI format (wasb://logs) and plain path (e.g., wasb-logs)
+ wasb_remote_base = remote_base_log_folder.removeprefix("wasb://")
+
REMOTE_TASK_LOG = WasbRemoteLogIO(
**(
{
"base_log_folder": BASE_LOG_FOLDER,
- "remote_base": remote_base_log_folder,
+ "remote_base": wasb_remote_base,
"delete_local_copy": delete_local_copy,
"wasb_container": wasb_log_container,
}