pandajedi/jeditest/addContWoSoTask.py

0001 import sys
0002 import uuid
0003
0004 from userinterface import Client
0005
0006 inFileList = ["file1", "file2", "file3"]
0007
0008 logDatasetName = f"panda.jeditest.log.{uuid.uuid4()}"
0009
0010 taskParamMap = {}
0011
0012 taskParamMap["nFilesPerJob"] = 1
0013 taskParamMap["nFiles"] = len(inFileList)
0014 # taskParamMap['nEventsPerInputFile']  = 10000
0015 # taskParamMap['nEventsPerJob'] = 10000
0016 # taskParamMap['nEvents'] = 25000
0017 taskParamMap["noInput"] = True
0018 taskParamMap["pfnList"] = inFileList
0019 # taskParamMap['mergeOutput'] = True
0020 taskParamMap["taskName"] = str(uuid.uuid4())
0021 taskParamMap["userName"] = "someone"
0022 taskParamMap["vo"] = "wlcg"
0023 taskParamMap["taskPriority"] = 900
0024 # taskParamMap['reqID'] = reqIdx
0025 taskParamMap["architecture"] = ""
0026 taskParamMap["transUses"] = ""
0027 taskParamMap["transHome"] = None
0028 taskParamMap["transPath"] = "https://atlpan.web.cern.ch/atlpan/bash-c"
0029 taskParamMap["processingType"] = "step1"
0030 taskParamMap["prodSourceLabel"] = "test"
0031 taskParamMap["taskType"] = "test"
0032 taskParamMap["workingGroup"] = "lsst"
0033 # taskParamMap['coreCount'] = 1
0034 # taskParamMap['walltime'] = 1
0035 taskParamMap["cloud"] = "US"
0036 taskParamMap["site"] = "BNL_OSG_1"
0037
0038 """
0039 taskParamMap['log'] = {'dataset': logDatasetName,
0040                        'type':'template',
0041                        'param_type':'log',
0042                        'token':'local',
0043                        'destination':'local',
0044                        'value':'{0}.${{SN}}.log.tgz'.format(logDatasetName)}
0045 """
0046
0047 taskParamMap["jobParameters"] = [
0048     {
0049         "type": "constant",
0050         "value": 'singularity exec docker://busybox echo "hello world with ${IN/L}"',
0051     },
0052 ]
0053
0054 print(Client.insertTaskParams(taskParamMap))