File indexing completed on 2026-04-10 08:39:00
0001 import sys
0002
0003 from pandajedi.jedicore.FactoryBase import FactoryBase
0004 from pandajedi.jedicore.JediTaskBufferInterface import JediTaskBufferInterface
0005 from pandajedi.jediddm.DDMInterface import DDMInterface
0006 from pandajedi.jediorder.TaskBroker import TaskBroker
0007
0008 tbIF = JediTaskBufferInterface()
0009 tbIF.setupInterface()
0010
0011 siteMapper = tbIF.get_site_mapper()
0012
0013
0014 ddmIF = DDMInterface()
0015 ddmIF.setupInterface()
0016
0017 jedi_task_id = int(sys.argv[1])
0018
0019 s, task_spec = tbIF.getTaskWithID_JEDI(jedi_task_id)
0020
0021 vo = task_spec.vo
0022 prodSourceLabel = task_spec.prodSourceLabel
0023 resource_type = task_spec.resource_type
0024 queue_id = task_spec.workQueue_ID
0025 gshare_name = task_spec.gshare
0026
0027 work_queue = tbIF.getWorkQueueMap().getQueueWithIDGshare(queue_id, gshare_name)
0028
0029
0030 task_list = tbIF.getTasksToBeProcessed_JEDI(None, None, None, None, None, simTasks=[jedi_task_id], readMinFiles=True, fullSimulation=True)
0031 for ts in task_list:
0032 for t in ts[1]:
0033 t[0].nucleus = None
0034
0035 task_broker = TaskBroker(None, tbIF, ddmIF, [vo], [prodSourceLabel])
0036 FactoryBase.initializeMods(task_broker, task_broker.taskBufferIF, task_broker.ddmIF)
0037 impl = task_broker.getImpl(vo, prodSourceLabel)
0038 impl.doBrokerage(task_list, vo, prodSourceLabel, work_queue, resource_type)
