|
23 | 23 | from rez.exceptions import PackageCacheError |
24 | 24 | from rez.vendor.lockfile import LockFile, NotLocked |
25 | 25 | from rez.vendor.progress.spinner import PixelSpinner |
26 | | -from rez.utils.filesystem import safe_listdir, safe_makedirs, safe_remove, \ |
27 | | - forceful_rmtree |
| 26 | +from rez.utils.filesystem import forceful_rmtree, safe_listdir, safe_remove |
28 | 27 | from rez.utils.colorize import ColorizedStreamHandler |
29 | 28 | from rez.utils.logging_ import print_warning |
30 | 29 | from rez.packages import get_variant |
@@ -99,9 +98,9 @@ def __init__(self, path): |
99 | 98 | self.path = path |
100 | 99 |
|
101 | 100 | # make dirs for internal use |
102 | | - safe_makedirs(self._log_dir) |
103 | | - safe_makedirs(self._pending_dir) |
104 | | - safe_makedirs(self._remove_dir) |
| 101 | + os.makedirs(self._log_dir, exist_ok=True) |
| 102 | + os.makedirs(self._pending_dir, exist_ok=True) |
| 103 | + os.makedirs(self._remove_dir, exist_ok=True) |
105 | 104 |
|
106 | 105 | def get_cached_root(self, variant): |
107 | 106 | """Get location of variant payload copy. |
@@ -171,7 +170,6 @@ def add_variant(self, variant, force=False, wait_for_copying=False, logger=None) |
171 | 170 | - int: One of VARIANT_FOUND, VARIANT_CREATED, VARIANT_COPYING, VARIANT_COPY_STALLED |
172 | 171 | """ |
173 | 172 | from rez.utils.base26 import get_next_base26 |
174 | | - from rez.utils.filesystem import safe_makedirs |
175 | 173 |
|
176 | 174 | # do some sanity checking on variant to cache |
177 | 175 | package = variant.parent |
@@ -262,7 +260,7 @@ def add_variant(self, variant, force=False, wait_for_copying=False, logger=None) |
262 | 260 |
|
263 | 261 | # 1. |
264 | 262 | path = self._get_hash_path(variant) |
265 | | - safe_makedirs(path) |
| 263 | + os.makedirs(path, exist_ok=True) |
266 | 264 |
|
267 | 265 | # construct data to store to json file |
268 | 266 | data = { |
|
0 commit comments