Warning, file /harvester/pandaharvester/harvestertest/getJob.py was not indexed
or was modified since last indexation (in which case cross-reference links may be missing, inaccurate or erroneous).
0001 import os
0002 import sys
0003
0004 from pandaharvester.harvestercore.db_proxy_pool import DBProxyPool as DBProxy
0005 from pandaharvester.harvestermessenger import shared_file_messenger
0006
0007 workerID = int(sys.argv[1])
0008
0009
0010 proxy = DBProxy()
0011 workSpec = proxy.get_worker_with_id(workerID)
0012
0013 accessPoint = workSpec.get_access_point()
0014
0015 try:
0016 os.makedirs(accessPoint)
0017 except BaseException:
0018 pass
0019
0020
0021 f = open(os.path.join(accessPoint, shared_file_messenger.jsonJobRequestFileName), "w")
0022 f.close()
