@@ -65,8 +65,8 @@ def arg_parser(): # type: () -> argparse.ArgumentParser
65
65
parser .add_argument ("--no-container" , action = "store_false" , default = True ,
66
66
help = "Do not execute jobs in a Docker container, even when specified by the CommandLineTool" ,
67
67
dest = "use_container" )
68
- parser .add_argument ("--executor " , type = Text , choices = { "single " , "parallel" }, default = "single" ,
69
- help = "Workflow executor type: sequential/multithreaded. Default: sequential " )
68
+ parser .add_argument ("--parallel " , action = "store_true " , default = False ,
69
+ help = "Run jobs in parallel " )
70
70
parser .add_argument ("--preserve-environment" , type = Text , action = "append" ,
71
71
help = "Preserve specific environment variable when running CommandLineTools. May be provided multiple times." ,
72
72
metavar = "ENVVAR" ,
@@ -900,15 +900,10 @@ def main(argsl=None, # type: List[str]
900
900
return e .code
901
901
902
902
if not executor :
903
- if args .executor == "single" :
904
- executor = SingleJobExecutor ()
905
- elif args .executor == "parallel" :
903
+ if args .parallel :
906
904
executor = MultithreadedJobExecutor ()
907
905
else :
908
- _logger .error ("Unknow type of executor: {0}" .format (args .executor ))
909
- arg_parser ().print_help ()
910
- return 1
911
-
906
+ executor = SingleJobExecutor ()
912
907
913
908
if isinstance (job_order_object , int ):
914
909
return job_order_object
0 commit comments