14 run = WorkflowRun.Run3
19 options = parser.parse_args()
24 if options.generation:
25 dsid =
"421356" if not options.dsid
else options.dsid
26 tests_to_run.append(GenerationTest(f
"gen{dsid}", run, WorkflowType.Generation, [
"generate"], setup, options.extra_args))
27 elif options.simulation:
28 if not options.workflow
or options.workflow
is WorkflowType.FullSim:
29 ami_tag =
"s4006" if not options.ami_tag
else options.ami_tag
30 tests_to_run.append(SimulationTest(ami_tag, run, WorkflowType.FullSim, [
"EVNTtoHITS"], setup, options.extra_args +
" --conditionsTag 'default:OFLCOND-MC21-SDR-RUN3-07' --geometryVersion 'default:ATLAS-R3S-2021-03-02-00'"))
31 if options.workflow
is WorkflowType.AF3:
32 ami_tag =
"a913" if not options.ami_tag
else options.ami_tag
33 tests_to_run.append(SimulationTest(ami_tag, run, WorkflowType.AF3, [
"EVNTtoHITS"], setup, options.extra_args))
34 if options.workflow
is WorkflowType.HitsMerge:
35 ami_tag =
"s4007" if not options.ami_tag
else options.ami_tag
36 tests_to_run.append(SimulationTest(ami_tag, run, WorkflowType.HitsMerge, [
"HITSMerge"], setup, options.extra_args))
37 if options.workflow
is WorkflowType.HitsFilter:
38 ami_tag =
"s4008" if not options.ami_tag
else options.ami_tag
39 tests_to_run.append(SimulationTest(ami_tag, run, WorkflowType.HitsFilter, [
"FilterHitTf"], setup, options.extra_args))
41 if not options.workflow
or options.workflow
is WorkflowType.MCOverlay:
42 tests_to_run.append(OverlayTest(
"d1759", run, WorkflowType.MCOverlay, [
"Overlay"], setup, options.extra_args +
" --runNumber 601229 --conditionsTag 'default:OFLCOND-MC23-SDR-RUN3-05'"))
44 if setup.parallel_execution:
45 log.error(
"Parallel execution not supported for pile-up workflow")
47 if not options.workflow
or options.workflow
is WorkflowType.PileUpPresampling:
48 ami_tag =
"d1919" if not options.ami_tag
else options.ami_tag
49 tests_to_run.append(PileUpTest(ami_tag, run, WorkflowType.PileUpPresampling, [
"HITtoRDO"], setup, options.extra_args))
50 if not options.workflow
or options.workflow
is WorkflowType.MCPileUpReco:
51 tests_to_run.append(QTest(
"q455", run, WorkflowType.MCPileUpReco, [
"Overlay",
"RDOtoRDOTrigger",
"RAWtoALL"], setup, options.extra_args))
52 if options.workflow
is WorkflowType.MinbiasPreprocessing:
53 ami_tag =
"d2008" if not options.ami_tag
else options.ami_tag
54 tests_to_run.append(DataOverlayPreparationTest(ami_tag, run, WorkflowType.MinbiasPreprocessing, [
"BStoRDO"], setup, options.extra_args))
55 elif options.derivation:
56 test_id =
"MC_PHYS" if not options.ami_tag
else options.ami_tag
57 test_id = f
"{test_id}_{run.value}"
58 tests_to_run.append(DerivationTest(test_id, run, WorkflowType.Derivation, [
"Derivation"], setup, options.extra_args))
60 if not options.workflow
or options.workflow
is WorkflowType.MCReco:
61 ami_tag =
"q454" if not options.ami_tag
else options.ami_tag
62 tests_to_run.append(QTest(ami_tag, run, WorkflowType.MCReco, [
"HITtoRDO",
"RDOtoRDOTrigger",
"RAWtoALL"], setup, options.extra_args))
63 if not options.workflow
or options.workflow
is WorkflowType.DataReco:
64 ami_tag =
"q449" if not options.ami_tag
else options.ami_tag
65 tests_to_run.append(QTest(ami_tag, run, WorkflowType.DataReco, [
"RAWtoALL",
"DQHistogramMerge"], setup, options.extra_args))
74 all_passed =
run_checks(setup, tests_to_run, performance_checks)