@@ -392,21 +392,18 @@ def generate_parser(toolparser, tool, namemap, records):
392392
393393
394394def 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