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("/")
 

Reply via email to