pandajedi/jeditest/addNonAtlasTaskEnc.py

0001 import sys
0002 import uuid
0003
0004 from userinterface import Client
0005
0006 inFileList = ["file1"]
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["transPath"] = "https://atlpan.web.cern.ch/atlpan/bash-c-enc"
0030 taskParamMap["encJobParams"] = True
0031 taskParamMap["processingType"] = "step1"
0032 taskParamMap["prodSourceLabel"] = "test"
0033 taskParamMap["taskType"] = "test"
0034 taskParamMap["workingGroup"] = "lsst"
0035 # taskParamMap['coreCount'] = 1
0036 # taskParamMap['walltime'] = 1
0037 taskParamMap["cloud"] = "LSST"
0038 taskParamMap["site"] = "DOMA_LSST_GOOGLE_TEST"
0039 # taskParamMap['site'] = 'DOMA_LSST_SLAC_TEST'
0040
0041 # taskParamMap['ramCount'] = 1000
0042 taskParamMap["ramUnit"] = "MB"
0043
0044 """
0045 taskParamMap['log'] = {'dataset': logDatasetName,
0046                        'type':'template',
0047                        'param_type':'log',
0048                        'token':'local',
0049                        'destination':'local',
0050                        'value':'{0}.${{SN}}.log.tgz'.format(logDatasetName)}
0051 """
0052
0053 taskParamMap["jobParameters"] = [
0054     {
0055         "type": "constant",
0056         "value": "echo aaa; ls; echo",
0057     },
0058     {
0059         "type": "constant",
0060         "value": "\"'${IN/L}'\"",
0061     },
0062 ]
0063
0064 print(Client.insertTaskParams(taskParamMap))