fix(io.path): add missing conn_id to string representation of ObjectS…

…toragePath (#39313)
apache · Apr 30, 2024 · ddd3b5b · ddd3b5b
1 parent 4fa9fe1
commit ddd3b5b
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/airflow/io/path.py b/airflow/io/path.py
@@ -361,3 +361,9 @@ def deserialize(cls, data: dict, version: int) -> ObjectStoragePath:
         conn_id = data.pop("conn_id", None)
 
         return ObjectStoragePath(path, conn_id=conn_id, **_kwargs)
+
+    def __str__(self):
+        conn_id = self.storage_options.get("conn_id")
+        if self._protocol and conn_id:
+            return f"{self._protocol}://{conn_id}@{self.path}"
+        return super().__str__()
diff --git a/tests/io/test_path.py b/tests/io/test_path.py
@@ -403,3 +403,8 @@ def test_lazy_load(self):
 
         assert o.fs is not None
         assert o._fs_cached
+
+    @pytest.mark.parametrize("input_str", ("file:///tmp/foo", "s3://conn_id@bucket/test.txt"))
+    def test_str(self, input_str):
+        o = ObjectStoragePath(input_str)
+        assert str(o) == input_str