This is an automated email from the ASF dual-hosted git repository.
amoghdesai 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 180ec473e9c Fix XCom object storage backend path validation (#56244)
180ec473e9c is described below
commit 180ec473e9c9b0a5e00ed4b19b3254a053d204d0
Author: Amogh Desai <[email protected]>
AuthorDate: Tue Sep 30 13:21:34 2025 +0530
Fix XCom object storage backend path validation (#56244)
---
providers/common/io/src/airflow/providers/common/io/xcom/backend.py | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/providers/common/io/src/airflow/providers/common/io/xcom/backend.py
b/providers/common/io/src/airflow/providers/common/io/xcom/backend.py
index e4c08bf1809..971704f37f2 100644
--- a/providers/common/io/src/airflow/providers/common/io/xcom/backend.py
+++ b/providers/common/io/src/airflow/providers/common/io/xcom/backend.py
@@ -20,7 +20,6 @@ import contextlib
import json
import uuid
from functools import cache
-from pathlib import Path
from typing import TYPE_CHECKING, Any, TypeVar
from urllib.parse import urlsplit
@@ -102,7 +101,7 @@ class XComObjectStorageBackend(BaseXCom):
raise TypeError(f"Not a valid url: {data}") from None
if url.scheme:
- if not Path.is_relative_to(ObjectStoragePath(data), p):
+ if not ObjectStoragePath(data).is_relative_to(p):
raise ValueError(f"Invalid key: {data}")
return p / data.replace(str(p), "", 1).lstrip("/")