File indexing completed on 2026-04-20 07:59:01
0001 import os
0002 import sys
0003
0004 from pandaharvester.harvestercore.communicator_pool import CommunicatorPool
0005 from pandaharvester.harvestercore.db_proxy_pool import DBProxyPool as DBProxy
0006 from pandaharvester.harvestermessenger import shared_file_messenger
0007
0008 workerID = int(sys.argv[1])
0009
0010 proxy = DBProxy()
0011 workSpec = proxy.get_worker_with_id(workerID)
0012 jobSpec = proxy.get_jobs_with_worker_id(workerID, None)[0]
0013
0014 accessPoint = workSpec.get_access_point()
0015
0016 try:
0017 os.makedirs(accessPoint)
0018 except BaseException:
0019 pass
0020
0021 node = {}
0022 node["pandaID"] = jobSpec.PandaID
0023 node["jobsetID"] = jobSpec.jobParams["jobsetID"]
0024 node["taskID"] = jobSpec.taskID
0025
0026
0027 a = CommunicatorPool()
0028 tmpStat, tmpVal = a.getEventRanges(node)
0029
0030 mess = shared_file_messenger.SharedFileMessenger()
0031 mess.feed_events(workSpec, tmpVal)
