File indexing completed on 2026-04-19 08:00:05
0001 import datetime
0002 import logging
0003 import os
0004 import sys
0005
0006 from pandaharvester.harvesterconfig import harvester_config
0007
0008 try:
0009 os.remove(harvester_config.db.database_filename)
0010 except Exception:
0011 pass
0012 from pandaharvester.harvestercore.communicator_pool import CommunicatorPool
0013 from pandaharvester.harvestercore.db_proxy_pool import DBProxyPool as DBProxy
0014 from pandaharvester.harvestercore.job_spec import JobSpec
0015 from pandaharvester.harvestercore.queue_config_mapper import QueueConfigMapper
0016
0017 for loggerName, loggerObj in logging.Logger.manager.loggerDict.items():
0018 if loggerName.startswith("panda.log"):
0019 if len(loggerObj.handlers) == 0:
0020 continue
0021 if loggerName.split(".")[-1] in ["db_proxy"]:
0022 continue
0023 stdoutHandler = logging.StreamHandler(sys.stdout)
0024 stdoutHandler.setFormatter(loggerObj.handlers[0].formatter)
0025 loggerObj.addHandler(stdoutHandler)
0026
0027 queueConfigMapper = QueueConfigMapper()
0028
0029 proxy = DBProxy()
0030 proxy.make_tables(queueConfigMapper)
0031
0032 job = JobSpec()
0033 job.PandaID = 1
0034
0035
0036 job.modificationTime = datetime.datetime.now()
0037 proxy.insert_jobs([job])
0038
0039 newJob = proxy.get_job(1)
0040
0041
0042 a = CommunicatorPool()
0043 a.get_jobs("siteName", "nodeName", "prodSourceLabel", "computingElement", 1, {})
