File indexing completed on 2026-04-20 07:59:01
0001 import sys
0002 import uuid
0003
0004 from pandaharvester.harvestercore.communicator_pool import CommunicatorPool
0005 from pandaharvester.harvestercore.event_spec import EventSpec
0006 from pandaharvester.harvestercore.file_spec import FileSpec
0007 from pandaharvester.harvestercore.job_spec import JobSpec
0008
0009 rID = sys.argv[1]
0010 taskid = rID.split("-")[0]
0011 pandaid = int(rID.split("-")[1])
0012
0013 job = JobSpec()
0014 job.PandaID = pandaid
0015 event = EventSpec()
0016 file = FileSpec()
0017 file.status = "finished"
0018 file.objstoreID = 9575
0019 file.pathConvention = 1000
0020 file.lfn = str(uuid.uuid4().hex) + ".zip"
0021 file.fsize = 555
0022 file.chksum = "0d2a9dc9"
0023 event.eventRangeID = rID
0024 event.eventStatus = "finished"
0025 job.zipEventMap = {1: {"events": [event], "zip": file}}
0026
0027
0028 a = CommunicatorPool()
0029 a.update_jobs([job])
