File indexing completed on 2026-04-10 08:39:07
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 if len(sys.argv) > 1:
0010 site = sys.argv[1]
0011 else:
0012 site = None
0013
0014 dataset_name = f"panda.destDB.{str(uuid.uuid4())}"
0015 destination_se = None
0016
0017 job_list = []
0018
0019 n_jobs = 1
0020
0021 for i in range(n_jobs):
0022 job = JobSpec()
0023 job.jobDefinitionID = int(time.time()) % 10000
0024 job.jobName = "%s_%d" % (str(uuid.uuid4()), i)
0025 job.AtlasRelease = "Atlas-14.1.0"
0026 job.homepackage = "AtlasProduction/14.1.0.3"
0027 job.transformation = "csc_evgen_trf.py"
0028 job.destinationDBlock = dataset_name
0029 job.destinationSE = destination_se
0030 job.currentPriority = 100
0031 job.prodSourceLabel = "test"
0032 job.computingSite = site
0033 job.cloud = "US"
0034 job.cmtConfig = "i686-slc4-gcc34-opt"
0035
0036 file = FileSpec()
0037 file.lfn = f"{job.jobName}.evgen.pool.root"
0038 file.destinationDBlock = job.destinationDBlock
0039 file.destinationSE = job.destinationSE
0040 file.dataset = job.destinationDBlock
0041 file.destinationDBlockToken = "ATLASDATADISK"
0042 file.type = "output"
0043 job.addFile(file)
0044
0045 fileOL = FileSpec()
0046 fileOL.lfn = f"{job.jobName}.job.log.tgz"
0047 fileOL.destinationDBlock = job.destinationDBlock
0048 fileOL.destinationSE = job.destinationSE
0049 fileOL.dataset = job.destinationDBlock
0050 fileOL.destinationDBlockToken = "ATLASDATADISK"
0051 fileOL.type = "log"
0052 job.addFile(fileOL)
0053
0054 job.jobParameters = f"5144 1 5000 1 CSC.005144.PythiaZee.py {file.lfn} NONE NONE NONE"
0055 job_list.append(job)
0056
0057 for i in range(n_jobs):
0058 status, output = Client.submit_jobs(job_list)
0059 print("---------------------")
0060 print(f"Status: {status}. Output: {output}")
