|
18 | 18 |
|
19 | 19 | import shellescape
|
20 | 20 | from prov.model import PROV
|
21 |
| -from schema_salad.sourceline import SourceLine |
22 | 21 | from six import PY2, with_metaclass
|
23 | 22 | from typing_extensions import (TYPE_CHECKING, # pylint: disable=unused-import
|
24 | 23 | Text)
|
25 |
| -# move to a regular typing import when Python 3.3-3.6 is no longer supported |
| 24 | +from schema_salad.sourceline import SourceLine |
26 | 25 |
|
27 | 26 | from .builder import Builder, HasReqsHints # pylint: disable=unused-import
|
28 | 27 | from .context import RuntimeContext # pylint: disable=unused-import
|
29 | 28 | from .context import getdefault
|
30 | 29 | from .errors import WorkflowException
|
31 | 30 | from .loghandler import _logger
|
32 |
| -from .pathmapper import (MapperEnt, PathMapper, ensure_writable, |
33 |
| - ensure_non_writable) |
34 |
| -from .process import UnsupportedRequirement, stageFiles |
| 31 | +from .pathmapper import (MapperEnt, PathMapper, # pylint: disable=unused-import |
| 32 | + ensure_writable, ensure_non_writable) |
| 33 | +from .process import UnsupportedRequirement, stage_files |
35 | 34 | from .secrets import SecretStore # pylint: disable=unused-import
|
36 |
| -from .utils import \ |
37 |
| - bytes2str_in_dicts # pylint: disable=unused-import; pylint: disable=unused-import |
38 |
| -from .utils import (DEFAULT_TMP_PREFIX, Directory, copytree_with_merge, |
39 |
| - json_dump, json_dumps, onWindows, processes_to_kill, |
40 |
| - subprocess) |
| 35 | +from .utils import (DEFAULT_TMP_PREFIX, Directory, bytes2str_in_dicts, |
| 36 | + copytree_with_merge, json_dump, json_dumps, onWindows, |
| 37 | + processes_to_kill, subprocess) |
41 | 38 |
|
42 | 39 | if TYPE_CHECKING:
|
43 | 40 | from .provenance import CreateProvProfile # pylint: disable=unused-import
|
@@ -409,14 +406,17 @@ def run(self,
|
409 | 406 | if "PATH" not in env:
|
410 | 407 | env["PATH"] = str(os.environ["PATH"]) if onWindows() else os.environ["PATH"]
|
411 | 408 | if "SYSTEMROOT" not in env and "SYSTEMROOT" in os.environ:
|
412 |
| - env["SYSTEMROOT"] = str(os.environ["SYSTEMROOT"]) if onWindows() else os.environ["SYSTEMROOT"] |
| 409 | + env["SYSTEMROOT"] = str(os.environ["SYSTEMROOT"]) if onWindows() \ |
| 410 | + else os.environ["SYSTEMROOT"] |
413 | 411 |
|
414 |
| - stageFiles(self.pathmapper, ignoreWritable=True, symLink=True, secret_store=runtimeContext.secret_store) |
| 412 | + stage_files(self.pathmapper, ignore_writable=True, symlink=True, |
| 413 | + secret_store=runtimeContext.secret_store) |
415 | 414 | if self.generatemapper is not None:
|
416 |
| - stageFiles(self.generatemapper, ignoreWritable=self.inplace_update, |
417 |
| - symLink=True, secret_store=runtimeContext.secret_store) |
418 |
| - relink_initialworkdir(self.generatemapper, self.outdir, |
419 |
| - self.builder.outdir, inplace_update=self.inplace_update) |
| 415 | + stage_files(self.generatemapper, ignore_writable=self.inplace_update, |
| 416 | + symlink=True, secret_store=runtimeContext.secret_store) |
| 417 | + relink_initialworkdir( |
| 418 | + self.generatemapper, self.outdir, self.builder.outdir, |
| 419 | + inplace_update=self.inplace_update) |
420 | 420 |
|
421 | 421 | self._execute([], env, runtimeContext)
|
422 | 422 |
|
@@ -538,12 +538,11 @@ def add_volumes(self,
|
538 | 538 | new_path = self.create_file_and_add_volume(
|
539 | 539 | runtime, vol, host_outdir_tgt, secret_store)
|
540 | 540 | key = pathmapper.reversemap(vol.target)
|
541 |
| - if key: |
| 541 | + if key and new_path: |
542 | 542 | pathmapper.update(
|
543 | 543 | key[0], new_path, vol.target, vol.type, vol.staged)
|
544 | 544 |
|
545 |
| - def run(self, runtimeContext): |
546 |
| - # type: (RuntimeContext) -> None |
| 545 | + def run(self, runtimeContext): # type: (RuntimeContext) -> None |
547 | 546 | if not os.path.exists(self.tmpdir):
|
548 | 547 | os.makedirs(self.tmpdir)
|
549 | 548 | (docker_req, docker_is_req) = self.get_requirement("DockerRequirement")
|
|
0 commit comments