updates

Author: anjaliratnam-msft

adlfs/spec.py

@@ -1278,22 +1278,20 @@ async def _rm_files(
 
     sync_wrapper(_rm_files)
 
-    async def _rm_file(
-        self, path: typing.Union[str, typing.List[str]], delimiter: str = "/", **kwargs
-    ):
+    async def _rm_file(self, path: str, **kwargs):
         """Delete a file.
 
         Parameters
         ----------
         path: str
             File to delete.
         """
-        container_name, p, _ = self.split_path(path, delimiter=delimiter)
+        container_name, p, _ = self.split_path(path)
         try:
-            if p != "":
-                await self._rm_files(container_name, [p.rstrip(delimiter)])
-            else:
-                await self._rmdir(container_name)
+            async with self.service_client.get_container_client(
+                container=container_name
+            ) as cc:
+                await cc.delete_blob(p)
         except ResourceNotFoundError:
             pass
         except FileNotFoundError:

adlfs/tests/test_spec.py

@@ -2152,13 +2152,3 @@ def test_rm_file(storage):
     fs.rm_file(path)
     with pytest.raises(FileNotFoundError):
         fs.ls(path)
-
-
-def test_rm_file_nonempty_directory(storage):
-    fs = AzureBlobFileSystem(
-        account_name=storage.account_name,
-        connection_string=CONN_STR,
-    )
-    path = "data/root/a/"
-    fs.rm_file(path)
-    assert fs.ls("data/root/a/") == ["data/root/a/file.txt"]