pandajedi/jediorder/JediDaemon.py

0001 from pandacommon.pandalogger import logger_utils
0002
0003 from pandajedi.jediconfig import jedi_config
0004 from pandajedi.jedidaemons.utils import DaemonMaster
0005
0006 base_logger = logger_utils.setup_logger(__name__.split(".")[-1])
0007
0008
0009 # launch
0010 def launcher(taskBufferIF, ddmIF):
0011     tmp_log = logger_utils.make_logger(base_logger, method_name="launcher")
0012     tmp_log.debug("start")
0013     try:
0014         jedi_config.daemon.config
0015     except Exception as e:
0016         tmp_log.error(f"failed to read config json file; should not happen... {e.__class__.__name__}: {e}")
0017         raise e
0018     # whether to run daemons
0019     if not getattr(jedi_config.daemon, "enable", False):
0020         tmp_log.debug("daemon disabled ; skipped")
0021         return
0022     # parameters
0023     n_workers = getattr(jedi_config.daemon, "n_proc", 1)
0024     worker_lifetime = getattr(jedi_config.daemon, "proc_lifetime", 28800)
0025     # start
0026     agent = DaemonMaster(logger=tmp_log, n_workers=n_workers, worker_lifetime=worker_lifetime, tbuf=taskBufferIF, ddmif=ddmIF)
0027     agent.run()