Skip to content

Commit aeba354

Browse files
authored
Pass fetcher_constructor to load_job_order. (#246)
1 parent ab9e86e commit aeba354

File tree

1 file changed

+11
-13
lines changed

1 file changed

+11
-13
lines changed

cwltool/main.py

Lines changed: 11 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -392,21 +392,18 @@ def generate_parser(toolparser, tool, namemap, records):
392392

393393

394394
def load_job_order(args, t, stdin, print_input_deps=False, relative_deps=False,
395-
stdout=sys.stdout, make_fs_access=None):
396-
# type: (argparse.Namespace, Process, IO[Any], bool, bool, IO[Any], Callable[[Text], StdFsAccess]) -> Union[int, Tuple[Dict[Text, Any], Text]]
395+
stdout=sys.stdout, make_fs_access=None, fetcher_constructor=None):
396+
# type: (argparse.Namespace, Process, IO[Any], bool, bool, IO[Any], Callable[[Text], StdFsAccess], Callable[[Dict[unicode, unicode], requests.sessions.Session], Fetcher]) -> Union[int, Tuple[Dict[Text, Any], Text]]
397397

398398
job_order_object = None
399399

400-
if args.conformance_test:
401-
loader = Loader({})
402-
else:
403-
jobloaderctx = {
404-
u"path": {u"@type": u"@id"},
405-
u"location": {u"@type": u"@id"},
406-
u"format": {u"@type": u"@id"},
407-
u"id": u"@id"}
408-
jobloaderctx.update(t.metadata.get("$namespaces", {}))
409-
loader = Loader(jobloaderctx)
400+
jobloaderctx = {
401+
u"path": {u"@type": u"@id"},
402+
u"location": {u"@type": u"@id"},
403+
u"format": {u"@type": u"@id"},
404+
u"id": u"@id"}
405+
jobloaderctx.update(t.metadata.get("$namespaces", {}))
406+
loader = Loader(jobloaderctx, fetcher_constructor=fetcher_constructor)
410407

411408
if len(args.job_order) == 1 and args.job_order[0][0] != "-":
412409
job_order_file = args.job_order[0]
@@ -700,7 +697,8 @@ def main(argsl=None, # type: List[str]
700697
print_input_deps=args.print_input_deps,
701698
relative_deps=args.relative_deps,
702699
stdout=stdout,
703-
make_fs_access=make_fs_access)
700+
make_fs_access=make_fs_access,
701+
fetcher_constructor=fetcher_constructor)
704702

705703
if isinstance(job_order_object, int):
706704
return job_order_object

0 commit comments

Comments
 (0)