File indexing completed on 2026-04-20 07:59:01
0001 import os
0002 import sys
0003
0004 from pandaharvester.harvestercore.db_proxy_pool import DBProxyPool as DBProxy
0005
0006 workerID = int(sys.argv[1])
0007 status = sys.argv[2]
0008
0009 proxy = DBProxy()
0010 workSpec = proxy.get_worker_with_id(workerID)
0011
0012 accessPoint = workSpec.get_access_point()
0013
0014 try:
0015 os.makedirs(accessPoint)
0016 except BaseException:
0017 pass
0018
0019 f = open(os.path.join(accessPoint, "status.txt"), "w")
0020 f.write(status)
0021 f.close()
