pandaserver/test/testG4sim17.py

0001 import sys
0002 import time
0003 import uuid
0004
0005 from pandaserver.taskbuffer.FileSpec import FileSpec
0006 from pandaserver.taskbuffer.JobSpec import JobSpec
0007 from pandaserver.userinterface import Client
0008
0009 site = sys.argv[1]
0010 cloud = sys.argv[2]
0011
0012 prod_destination_block = "mc10_7TeV.105001.pythia_minbias.evgen.EVNT.e574_tid153937_00"
0013 input_file = "EVNT.153937._000184.pool.root.1"
0014
0015 if len(sys.argv) == 5:
0016     site = sys.argv[1]
0017     cloud = sys.argv[2]
0018     prod_destination_block = sys.argv[3]
0019     input_file = sys.argv[4]
0020
0021 datasetName = f"panda.destDB.{str(uuid.uuid4())}"
0022
0023 files = {
0024     input_file: None,
0025 }
0026
0027 job_list = []
0028
0029 index = 0
0030 for lfn in files:
0031     index += 1
0032     job = JobSpec()
0033     job.jobDefinitionID = (time.time()) % 10000
0034     job.jobName = "%s_%d" % (str(uuid.uuid4()), index)
0035     job.AtlasRelease = "Atlas-17.0.5"
0036     job.homepackage = "AtlasProduction/17.0.5.6"
0037     job.transformation = "AtlasG4_trf.py"
0038     job.destinationDBlock = datasetName
0039     job.computingSite = site
0040     job.prodDBlock = prod_destination_block
0041
0042     job.prodSourceLabel = "test"
0043     job.processingType = "test"
0044     job.currentPriority = 10000
0045     job.cloud = cloud
0046     job.cmtConfig = "i686-slc5-gcc43-opt"
0047
0048     fileI = FileSpec()
0049     fileI.dataset = job.prodDBlock
0050     fileI.prodDBlock = job.prodDBlock
0051     fileI.lfn = lfn
0052     fileI.type = "input"
0053     job.addFile(fileI)
0054
0055     fileD = FileSpec()
0056     fileD.dataset = "ddo.000001.Atlas.Ideal.DBRelease.v170602"
0057     fileD.prodDBlock = fileD.dataset
0058     fileD.lfn = "DBRelease-17.6.2.tar.gz"
0059     fileD.type = "input"
0060     job.addFile(fileD)
0061
0062     fileOA = FileSpec()
0063     fileOA.lfn = f"{job.jobName}.HITS.pool.root"
0064     fileOA.destinationDBlock = job.destinationDBlock
0065     fileOA.destinationSE = job.destinationSE
0066     fileOA.dataset = job.destinationDBlock
0067     fileOA.destinationDBlockToken = "ATLASDATADISK"
0068     fileOA.type = "output"
0069     job.addFile(fileOA)
0070
0071     fileOL = FileSpec()
0072     fileOL.lfn = f"{job.jobName}.job.log.tgz"
0073     fileOL.destinationDBlock = job.destinationDBlock
0074     fileOL.destinationSE = job.destinationSE
0075     fileOL.dataset = job.destinationDBlock
0076     fileOL.destinationDBlockToken = "ATLASDATADISK"
0077     fileOL.type = "log"
0078     job.addFile(fileOL)
0079     job.jobParameters = (
0080         f"inputEvgenFile={fileI.lfn} outputHitsFile={fileOA.lfn} maxEvents=3 skipEvents=0 "
0081         f"DBRelease={fileD.lfn} geometryVersion=ATLAS-GEO-18-01-03_VALIDATION "
0082         f"conditionsTag=OFLCOND-SDR-BS7T-05-14 randomSeed=1 physicsList=QGSP_BERT "
0083         f"RunNumber=116870 firstEvent=1"
0084     )
0085
0086     job_list.append(job)
0087
0088 status, output = Client.submit_jobs(job_list)
0089 print("---------------------")
0090 print(f"Status: {status}. Output: {output}")