Ensure remove accepts str and Path-like objects

dvc/external_repo.py

@@ -9,7 +9,7 @@
 
 from dvc.config import NoRemoteError
 from dvc.exceptions import RemoteNotSpecifiedInExternalRepoError
-from dvc.utils import remove
+from dvc.utils.fs import remove
 
 
 REPO_CACHE = {}

dvc/remote/local.py

@@ -26,13 +26,13 @@
 from dvc.utils import file_md5
 from dvc.utils import makedirs
 from dvc.utils import relpath
-from dvc.utils import remove
 from dvc.utils import tmp_fname
 from dvc.utils import walk_files
 from dvc.utils.compat import fspath_py35
 from dvc.utils.compat import open
 from dvc.utils.compat import str
 from dvc.utils.fs import move
+from dvc.utils.fs import remove
 
 logger = logging.getLogger(__name__)
 

dvc/repo/destroy.py

@@ -1,4 +1,4 @@
-from dvc.utils import remove
+from dvc.utils.fs import remove
 
 
 def destroy(self):

dvc/repo/get.py

@@ -11,8 +11,8 @@
 from dvc.path_info import PathInfo
 from dvc.stage import Stage
 from dvc.state import StateNoop
-from dvc.utils import remove
 from dvc.utils import resolve_output
+from dvc.utils.fs import remove
 
 logger = logging.getLogger(__name__)
 

dvc/repo/init.py

@@ -11,7 +11,7 @@
 from dvc.scm import SCM
 from dvc.utils import boxify
 from dvc.utils import relpath
-from dvc.utils import remove
+from dvc.utils.fs import remove
 
 logger = logging.getLogger(__name__)
 

dvc/state.py

@@ -10,14 +10,14 @@
 from dvc.exceptions import DvcException
 from dvc.utils import current_timestamp
 from dvc.utils import relpath
-from dvc.utils import remove
 from dvc.utils import to_chunks
 from dvc.utils.compat import fspath_py35
 from dvc.utils.compat import is_py2
 from dvc.utils.compat import urlencode
 from dvc.utils.compat import urlunparse
 from dvc.utils.fs import get_inode
 from dvc.utils.fs import get_mtime_and_size
+from dvc.utils.fs import remove
 
 
 SQLITE_MAX_VARIABLES_NUMBER = 999

dvc/utils/__init__.py

@@ -8,7 +8,6 @@
 import math
 import os
 import re
-import shutil
 import stat
 import sys
 import time
@@ -173,19 +172,6 @@ def _chmod(func, p, excinfo):
     func(p)
 
 
-def remove(path):
-    logger.debug("Removing '{}'".format(relpath(path)))
-
-    try:
-        if os.path.isdir(path):
-            shutil.rmtree(path, onerror=_chmod)
-        else:
-            _chmod(os.unlink, path, None)
-    except OSError as exc:
-        if exc.errno != errno.ENOENT:
-            raise
-
-
 def _split(list_to_split, chunk_size):
     return [
         list_to_split[i : i + chunk_size]

dvc/utils/fs.py

@@ -10,9 +10,11 @@
 
 from dvc.exceptions import DvcException
 from dvc.system import System
+from dvc.utils import _chmod
 from dvc.utils import dict_md5
 from dvc.utils import fspath
 from dvc.utils import fspath_py35
+from dvc.utils import relpath
 from dvc.utils import walk_files
 from dvc.utils.compat import str
 
@@ -103,3 +105,18 @@ def move(src, dst, mode=None):
         os.chmod(tmp, mode)
 
     shutil.move(tmp, dst)
+
+
+def remove(path):
+    path = fspath_py35(path)
+
+    logger.debug("Removing '{}'".format(relpath(path)))
+
+    try:
+        if os.path.isdir(path):
+            shutil.rmtree(path, onerror=_chmod)
+        else:
+            _chmod(os.unlink, path, None)
+    except OSError as exc:
+        if exc.errno != errno.ENOENT:
+            raise

tests/basic_env.py

@@ -13,9 +13,9 @@
 from git.exc import GitCommandNotFound
 
 from dvc.repo import Repo as DvcRepo
-from dvc.utils import remove
 from dvc.utils.compat import open
 from dvc.utils.compat import str
+from dvc.utils.fs import remove
 
 
 logger = logging.getLogger("dvc")

tests/unit/utils/test_fs.py

@@ -16,6 +16,7 @@
 from dvc.utils.fs import get_inode
 from dvc.utils.fs import get_mtime_and_size
 from dvc.utils.fs import move
+from dvc.utils.fs import remove
 from tests.basic_env import TestDir
 from tests.utils import spy
 
@@ -152,3 +153,14 @@ def test_move(repo_dir):
     move(src_info, dest_info)
     assert not os.path.isfile(src_info.fspath)
     assert len(os.listdir(dest_info.fspath)) == 1
+
+
+def test_remove(repo_dir):
+    path = repo_dir.FOO
+    path_info = PathInfo(repo_dir.BAR)
+
+    remove(path)
+    assert not os.path.isfile(path)
+
+    remove(path_info)
+    assert not os.path.isfile(path_info.fspath)