Implement write_local_file with opendal

Author: NickCao

jumpstarter/drivers/mixins.py

@@ -11,7 +11,6 @@
 
 from anyio import create_unix_listener
 from anyio.from_thread import BlockingPortal
-from anyio.streams.file import FileReadStream
 from opendal import Operator
 from pexpect.fdpexpect import fdspawn
 
@@ -70,20 +69,6 @@ def expect(self):
 class ResourceMixin:
     """Resource"""
 
-    @contextmanager
-    def local_file(
-        self,
-        filepath,
-    ):
-        """
-        Share local file with driver
-
-        :param str filepath: path to file
-        """
-        with self.portal.wrap_async_context_manager(self.portal.call(FileReadStream.from_path, filepath)) as file:
-            with self.portal.wrap_async_context_manager(self.resource_async(file)) as uuid:
-                yield uuid
-
     @contextmanager
     def file(self, operator: Operator, path: str):
         with self.portal.wrap_async_context_manager(self.file_async(operator.to_async_operator(), path)) as uuid:

jumpstarter/drivers/storage/base.py

@@ -45,7 +45,7 @@ def write_file(self, operator: Operator, path: str):
             return self.call("write", handle)
 
     def write_local_file(self, filepath):
-        with self.local_file(filepath) as handle:
+        with self.file(Operator("fs", root="/"), filepath) as handle:
             return self.call("write", handle)
 
     def cli(self):

jumpstarter/drivers/storage/base_test.py

@@ -1,3 +1,4 @@
+from pathlib import Path
 from tempfile import TemporaryDirectory
 
 import pytest
@@ -15,6 +16,7 @@ def test_drivers_mock_storage_mux_fs():
             fs.write("test", b"testcontent" * 1000)
 
             client.write_file(fs, "test")
+            client.write_local_file(str(Path(tempdir) / "test"))
 
 
 @pytest.mark.skip(reason="require minio")