Definition at line 3 of file CLIHelper.py.
◆ add_parser_options()
def CLIHelper.CLIHelper.add_parser_options |
( |
|
cls, |
|
|
|
parser |
|
) |
| |
Definition at line 29 of file CLIHelper.py.
29 def add_parser_options(cls, parser):
31 workflow_subparsers = parser.add_subparsers( help=
"workflow option help", dest=
"workflow" )
32 return workflow_subparsers
◆ fill_required_options_dict()
def CLIHelper.CLIHelper.fill_required_options_dict |
( |
|
self | ) |
|
Definition at line 39 of file CLIHelper.py.
References mps_setup.append, and DTWorkflow.DTWorkflow.required_options_dict.
39 def fill_required_options_dict(self):
40 common_required = [
"run"]
41 self.required_options_dict[
"submit"] = common_required
42 self.required_options_dict[
"submit"].
append(
"datasetpath")
43 self.required_options_dict[
"submit"].
append(
"globaltag")
45 self.required_options_dict[
"correction"] = common_required
46 self.required_options_dict[
"correction"].
append(
"globaltag")
◆ fill_required_options_prepare_dict()
def CLIHelper.CLIHelper.fill_required_options_prepare_dict |
( |
|
self | ) |
|
◆ get_check_options_parser()
def CLIHelper.CLIHelper.get_check_options_parser |
( |
|
cls | ) |
|
Return a parser object with options relevant to check the status of remote submission
Definition at line 115 of file CLIHelper.py.
Referenced by DTVdriftWorkflow.DTvdriftWorkflow.add_parser_options(), and DTTtrigWorkflow.DTttrigWorkflow.add_parser_options().
115 def get_check_options_parser(cls):
116 """ Return a parser object with options relevant to check the status of remote submission""" 117 check_opts_parser = argparse.ArgumentParser(add_help=
False)
118 check_opts_group = check_opts_parser.add_argument_group(
119 description =
"Options for Job submission")
120 check_opts_group.add_argument(
"--check-interval", default = 600,type=int,
121 help=
"Time in seconds between check operations default: %(default)s")
122 check_opts_group.add_argument(
"--max-checks", default =1000, type=int,
123 help=
"Maximum number of checks before check is considered failed default: %(default)s")
124 return check_opts_parser
◆ get_common_options_parser()
def CLIHelper.CLIHelper.get_common_options_parser |
( |
|
cls | ) |
|
Return a parser with common options for each workflow
Definition at line 5 of file CLIHelper.py.
Referenced by DTT0WireWorkflow.DTT0WireWorkflow.add_parser_options(), DTVdriftWorkflow.DTvdriftWorkflow.add_parser_options(), and DTTtrigWorkflow.DTttrigWorkflow.add_parser_options().
5 def get_common_options_parser(cls):
6 """ Return a parser with common options for each workflow""" 7 common_opts_parser = argparse.ArgumentParser(add_help=
False)
8 common_opts_group = common_opts_parser.add_argument_group(
9 description =
"General options")
10 common_opts_group.add_argument(
"-r",
"--run", type=int,
11 help=
"set reference run number (typically first or last run in list)")
12 common_opts_group.add_argument(
"--trial", type=int, default = 1,
13 help=
"trial number used in the naming of output directories")
14 common_opts_group.add_argument(
"--label", default=
"dtCalibration",
15 help=
"label used in the naming of workflow output default:%(default)s")
16 common_opts_group.add_argument(
"--datasettype", default =
"Data",
17 choices=[
"Data",
"Cosmics",
"MC"], help=
"Type of input dataset default: %(default)s")
18 common_opts_group.add_argument(
"--config-path",
19 help=
"Path to alternative workflow config json file, e.g. used to submit the job")
20 common_opts_group.add_argument(
"--user", default=
"",
21 help=
"User used e.g. for submission. Defaults to user HN name")
22 common_opts_group.add_argument(
"--working-dir",
23 default=os.getcwd(), help=
"connect string default:%(default)s")
24 common_opts_group.add_argument(
"--no-exec",
25 action=
"store_true", help=
"Do not execute or submit any workflow")
26 return common_opts_parser
◆ get_dump_options_parser()
def CLIHelper.CLIHelper.get_dump_options_parser |
( |
|
cls | ) |
|
Definition at line 137 of file CLIHelper.py.
Referenced by DTVdriftWorkflow.DTvdriftWorkflow.add_parser_options(), and DTTtrigWorkflow.DTttrigWorkflow.add_parser_options().
137 def get_dump_options_parser(cls):
138 dump_opts_parser = argparse.ArgumentParser(add_help=
False)
139 dump_opts_group = dump_opts_parser.add_argument_group(
140 description =
"Options for dump db file")
141 dump_opts_group.add_argument(
"--input-dumpDB",
142 help=
"Input database file to dump."\
143 " Defaults to existing corrected database from correction command"\
144 " if run, label, trial or input config are specified")
145 return dump_opts_group
◆ get_input_db_options_parser()
def CLIHelper.CLIHelper.get_input_db_options_parser |
( |
|
cls | ) |
|
Return a parser object with options relevant for input databases
Definition at line 50 of file CLIHelper.py.
Referenced by DTT0WireWorkflow.DTT0WireWorkflow.add_parser_options(), DTVdriftWorkflow.DTvdriftWorkflow.add_parser_options(), and DTTtrigWorkflow.DTttrigWorkflow.add_parser_options().
50 def get_input_db_options_parser(cls):
51 """ Return a parser object with options relevant for input databases""" 52 db_opts_parser = argparse.ArgumentParser(add_help=
False)
53 dp_opts_group = db_opts_parser.add_argument_group(
54 description =
"Options for Input databases")
55 db_opts_parser.add_argument(
"--inputDBRcd",
56 help=
"Record used for PoolDBESSource")
57 db_opts_parser.add_argument(
"--inputDBTag",
58 help=
"Tag used for PoolDBESSource")
59 db_opts_parser.add_argument(
"--connectStrDBTag",
60 default=
'frontier://FrontierProd/CMS_COND_31X_DT',
61 help=
"connect string default:%(default)s")
◆ get_local_input_db_options_parser()
def CLIHelper.CLIHelper.get_local_input_db_options_parser |
( |
|
cls | ) |
|
◆ get_submission_options_parser()
def CLIHelper.CLIHelper.get_submission_options_parser |
( |
|
cls | ) |
|
Return a parser object with options relevant to remote submission
Definition at line 79 of file CLIHelper.py.
Referenced by DTT0WireWorkflow.DTT0WireWorkflow.add_parser_options(), DTVdriftWorkflow.DTvdriftWorkflow.add_parser_options(), and DTTtrigWorkflow.DTttrigWorkflow.add_parser_options().
79 def get_submission_options_parser(cls):
80 """ Return a parser object with options relevant to remote submission""" 81 submission_opts_parser = argparse.ArgumentParser(add_help=
False)
82 submission_opts_group = submission_opts_parser.add_argument_group(
83 description =
"Options for Job submission")
84 submission_opts_group.add_argument(
"--datasetpath",
85 help=
"dataset name to process")
86 submission_opts_group.add_argument(
"--run-on-RAW", action =
"store_true",
87 help=
"Flag if run on RAW dataset")
88 submission_opts_group.add_argument(
"--fromMuons", action =
"store_true",
89 help=
"Segment selection using muon-segment matching")
90 submission_opts_group.add_argument(
"--globaltag",
91 help=
"global tag identifier (with the '::All' string, if necessary)")
92 submission_opts_group.add_argument(
"--histoRange", default = 0.4,
93 help=
"Range or residual histogram, default is 0.4cm")
94 submission_opts_group.add_argument(
"--runselection", default = [], nargs=
"+",
95 help=
"run list or range")
96 submission_opts_group.add_argument(
"--filesPerJob", default = 5,
97 help=
"Number of files to process for MC grid jobs")
98 submission_opts_group.add_argument(
"--lumisPerJob", default = 10000,
99 help=
"Number of lumi sections to process for RAW / Comsics grid jobs")
100 submission_opts_group.add_argument(
"--preselection", dest=
"preselection",
101 help=
"configuration fragment and sequence name, separated by a ':', defining a pre-selection filter")
102 submission_opts_group.add_argument(
"--raw-data-label", dest=
"raw_data_label", default=
"rawDataCollector",
103 help=
"RAW Data label as in the sample file.")
104 submission_opts_group.add_argument(
"--output-site", default =
"T2_DE_RWTH",
105 help=
"Site used for stage out of results")
106 submission_opts_group.add_argument(
"--ce-black-list", default = [], nargs=
"+",
107 help=
"add sites to black list when run on Grid")
108 submission_opts_group.add_argument(
"--ce-white-list", default = [], nargs=
"+",
109 help=
"add sites to white list when run on Grid")
110 submission_opts_group.add_argument(
"--no-log",
111 action=
"store_true", help=
"Do not transfer crab logs:%(default)s")
112 return submission_opts_parser
◆ get_write_options_parser()
def CLIHelper.CLIHelper.get_write_options_parser |
( |
|
cls | ) |
|
Return a parser object with options relevant to write results to dbs
Definition at line 127 of file CLIHelper.py.
Referenced by DTVdriftWorkflow.DTvdriftWorkflow.add_parser_options(), and DTTtrigWorkflow.DTttrigWorkflow.add_parser_options().
127 def get_write_options_parser(cls):
128 """ Return a parser object with options relevant to write results to dbs""" 129 check_opts_parser = argparse.ArgumentParser(add_help=
False)
130 check_opts_group = check_opts_parser.add_argument_group(
131 description =
"Options for write jobs")
132 check_opts_group.add_argument(
"--skip-stageout", action=
"store_true",
133 help=
"Skip stageout to local disk and merging")
134 return check_opts_parser