diff --git a/training/deepspeech_training/util/taskcluster.py b/training/deepspeech_training/util/taskcluster.py index 4471659d..13829bdf 100644 --- a/training/deepspeech_training/util/taskcluster.py +++ b/training/deepspeech_training/util/taskcluster.py @@ -14,8 +14,6 @@ import sys from pkg_resources import parse_version -from .io import isdir_remote, open_remote, is_remote_path - DEFAULT_SCHEMES = { 'deepspeech': 'https://community-tc.services.mozilla.com/api/index/v1/task/project.deepspeech.deepspeech.native_client.%(branch_name)s.%(arch_string)s/artifacts/public/%(artifact_name)s', 'tensorflow': 'https://community-tc.services.mozilla.com/api/index/v1/task/project.deepspeech.tensorflow.pip.%(branch_name)s.%(arch_string)s/artifacts/public/%(artifact_name)s' @@ -43,7 +41,7 @@ def maybe_download_tc(target_dir, tc_url, progress=True): assert target_dir is not None - if not is_remote_path(target_dir): + if not os.path.isdir(target_dir): try: os.makedirs(target_dir) except OSError as e: @@ -62,7 +60,7 @@ def maybe_download_tc(target_dir, tc_url, progress=True): print('File already exists: %s' % target_file) if is_gzip: - with open_remote(target_file, "r+b") as frw: + with open(target_file, "r+b") as frw: decompressed = gzip.decompress(frw.read()) frw.seek(0) frw.write(decompressed)