|
37 | 37 | parser = argparse.ArgumentParser(description='Create an ALICE (Run3) MC simulation workflow') |
38 | 38 |
|
39 | 39 | # the run-number of data taking or default if unanchored |
40 | | -parser.add_argument('-run',help="Run number for this MC", default=300000) |
| 40 | +parser.add_argument('-run', type=int, help="Run number for this MC", default=300000) |
41 | 41 | parser.add_argument('-productionTag',help="Production tag for this MC", default='unknown') |
42 | 42 | # the timestamp at which this MC workflow will be run |
43 | 43 | # - in principle it should be consistent with the time of the "run" number above |
44 | 44 | # - some external tool should sample it within |
45 | 45 | # - we can also sample it ourselfs here |
46 | | -parser.add_argument('--timestamp',help="Anchoring timestamp (defaults to now)", default=-1) |
| 46 | +parser.add_argument('--timestamp', type=int, help="Anchoring timestamp (defaults to now)", default=-1) |
47 | 47 | parser.add_argument('--anchor-config',help="JSON file to contextualise workflow with external configs (config values etc.) for instance comping from data reco workflows.", default='') |
48 | 48 | parser.add_argument('-ns',help='number of signal events / timeframe', default=20) |
49 | 49 | parser.add_argument('-gen',help='generator: pythia8, extgen', default='') |
@@ -206,7 +206,7 @@ def retrieve_sor(run_number): |
206 | 206 | SOR=match_object[2] |
207 | 207 | break |
208 | 208 |
|
209 | | - return SOR |
| 209 | + return int(SOR) |
210 | 210 |
|
211 | 211 |
|
212 | 212 | # ----------- START WORKFLOW CONSTRUCTION ----------------------------- |
@@ -516,7 +516,7 @@ def getDPL_global_options(bigshm=False): |
516 | 516 | + ' --field ' + str(BFIELD) + ' -j ' + str(NWORKERS) + ' -g ' + str(GENERATOR) \ |
517 | 517 | + ' ' + str(TRIGGER) + ' ' + str(CONFKEY) + ' ' + str(INIFILE) \ |
518 | 518 | + ' -o ' + signalprefix + ' ' + embeddinto \ |
519 | | - + (' --timestamp ' + str(args.timestamp))[args.timestamp!=-1] + ' --run ' + args.run |
| 519 | + + ('', ' --timestamp ' + str(args.timestamp))[args.timestamp!=-1] + ' --run ' + str(args.run) |
520 | 520 | if not "all" in activeDetectors: |
521 | 521 | SGNtask['cmd'] += ' --readoutDetectors ' + " ".join(activeDetectors) |
522 | 522 | workflow['stages'].append(SGNtask) |
@@ -901,7 +901,7 @@ def getDigiTaskName(det): |
901 | 901 | if isActive("MID"): |
902 | 902 | pvfinder_matching_sources += ",MID" |
903 | 903 | pvfinderneeds += [MIDRECOtask['name']] |
904 | | - |
| 904 | + |
905 | 905 | PVFINDERtask = createTask(name='pvfinder_'+str(tf), needs=pvfinderneeds, tf=tf, cwd=timeframeworkdir, lab=["RECO"], cpu=NWORKERS, mem='4000') |
906 | 906 | PVFINDERtask['cmd'] = '${O2_ROOT}/bin/o2-primary-vertexing-workflow ' \ |
907 | 907 | + getDPL_global_options() + putConfigValuesNew(['ITSAlpideParam','MFTAlpideParam', 'pvertexer', 'TPCGasParam'], {"NameConf.mDirMatLUT" : ".."}) |
|
0 commit comments