18 def __init__(self, ID: str, run: WorkflowRun, type: WorkflowType, steps: List[str], setup: TestSetup, extra_args: str = "") -> None:
19 if "maxEvents" not in extra_args:
20 if type == WorkflowType.MCPileUpReco or run == WorkflowRun.Run4:
21 extra_args += " --maxEvents 5"
22 else:
23 extra_args += " --maxEvents 20"
24
25 if type == WorkflowType.MCPileUpReco:
26 if "inputHITSFile" not in extra_args:
27 extra_args += f" --inputHITSFile {input_HITS[run]}"
28 if "inputRDO_BKGFile" not in extra_args:
29 extra_args += " --inputRDO_BKGFile ../run_d*/myRDO.pool.root"
30
31 threads = 1
32 threads_argument = '--multithreaded'
33 if setup.custom_threads is not None:
34 threads = setup.custom_threads
35 if threads <= 0:
36 threads_argument = ''
37
38 self.command = \
39 (f"ATHENA_CORE_NUMBER={threads} Reco_tf.py {threads_argument} --AMIConfig {ID}"
40 f" --imf False {extra_args}")
41
42 self.output_checks = []
43
44
45
46 self.output_checks.append(FrozenTier0PolicyCheck(setup, "AOD", 60))
47 self.output_checks.append(FrozenTier0PolicyCheck(setup, "ESD", 20))
48 self.output_checks.append(MetadataCheck(setup, "AOD"))
49
50 self.digest_checks = []
51 if not setup.disable_output_checks:
52 self.digest_checks.append(AODContentCheck(setup))
53 self.digest_checks.append(AODDigestCheck(setup))
54
55 super().__init__(ID, run, type, steps, setup)
56
57
1.14.0