fix(bulk_writer): handle relative remote writer paths

Resolve RemoteBulkWriter upload paths against the resolved local data path before computing object-relative paths.

Add regression coverage for relative local_path values.

Co-authored-by: XuanYang-cn <51370125+XuanYang-cn@users.noreply.github.com>

Author: VectorPeak

pymilvus/bulk_writer/remote_bulk_writer.py

@@ -295,11 +295,12 @@ def _upload(self, file_list: list):
                     continue
 
                 relative_file_path = (
-                    Path(file_path).resolve().relative_to(super().data_path).as_posix()
-                )
-                minio_file_path = (
-                    f"{self._remote_path.as_posix().strip('/')}/{relative_file_path}"
+                    Path(file_path)
+                    .resolve()
+                    .relative_to(Path(super().data_path).resolve())
+                    .as_posix()
                 )
+                minio_file_path = f"{self._remote_path.as_posix().strip('/')}/{relative_file_path}"
 
                 if self._object_exists(minio_file_path):
                     logger.info(

tests/unit/test_remote_bulk_writer.py

@@ -1,4 +1,5 @@
 from contextlib import ExitStack
+from pathlib import Path
 from unittest.mock import MagicMock, patch
 
 from pymilvus.bulk_writer.constants import BulkFileType
@@ -122,3 +123,31 @@ def test_upload_jsonl_file(self, tmp_path):
         assert "\\" not in kwargs["object_name"]
         mock_local_rm.assert_called_once_with(str(jsonl_file))
         assert writer.batch_files[0][0] == uploaded_files[0]
+
+    def test_upload_jsonl_file_with_relative_local_path(self, tmp_path, monkeypatch):
+        monkeypatch.chdir(tmp_path)
+        relative_local_path = Path("relative-bulk")
+
+        writer = RemoteBulkWriter(
+            schema=self._simple_schema(),
+            remote_path="bulk/test",
+            connect_param=None,
+            file_type=BulkFileType.JSONL,
+            local_path=str(relative_local_path),
+        )
+        jsonl_file = writer._local_path / "1.jsonl"
+        jsonl_file.write_text('{"id":1,"vector":[1.0,2.0,3.0,4.0]}\n')
+
+        with ExitStack() as stack:
+            stack.enter_context(patch.object(writer, "_bucket_exists", return_value=True))
+            stack.enter_context(patch.object(writer, "_object_exists", return_value=False))
+            mock_upload_object = stack.enter_context(patch.object(writer, "_upload_object"))
+            stack.enter_context(patch.object(writer, "_local_rm"))
+            uploaded_files = writer._upload([str(jsonl_file)])
+
+        assert len(uploaded_files) == 1
+        _, kwargs = mock_upload_object.call_args
+        assert kwargs["object_name"] == uploaded_files[0]
+        assert kwargs["object_name"].endswith("/1.jsonl")
+        assert "bulk/test/" in kwargs["object_name"]
+        assert "\\" not in kwargs["object_name"]