File indexing completed on 2026-04-20 07:59:01
0001 import json
0002 import os
0003 import sys
0004
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 eventID = sys.argv[2]
0011 status = sys.argv[3]
0012
0013 proxy = DBProxy()
0014 workSpec = proxy.get_worker_with_id(workerID)
0015 jobSpec = proxy.get_jobs_with_worker_id(workerID, None)[0]
0016
0017 accessPoint = workSpec.get_access_point()
0018
0019 try:
0020 os.makedirs(accessPoint)
0021 except BaseException:
0022 pass
0023
0024 node = {}
0025 node["eventRangeID"] = eventID
0026 node["eventStatus"] = status
0027
0028 f = open(os.path.join(accessPoint, shared_file_messenger.jsonEventsUpdateFileName), "w")
0029 json.dump([node], f)
0030 f.close()
0031
0032 if status == "finished":
0033 lfn = id + ".data"
0034 data = {}
0035 data["path"] = os.path.join(accessPoint, lfn)
0036 data["type"] = "output"
0037 data["fsize"] = 10 * 1024 * 1024
0038 data["eventRangeID"] = eventID
0039 node = {}
0040 node[lfn] = data
0041 f = open(os.path.join(accessPoint, shared_file_messenger.jsonOutputsFileName), "w")
0042 json.dump(node, f)
0043 f.close()
