pandajedi/jedidog/AsyncRequestWatchDog.py

0001 from pandacommon.pandalogger.PandaLogger import PandaLogger
0002
0003 from pandajedi.jedicore.MsgWrapper import MsgWrapper
0004 from pandaserver.asyncprocess import processor
0005
0006 from .WatchDogBase import WatchDogBase
0007
0008 logger = PandaLogger().getLogger(__name__.split(".")[-1])
0009
0010
0011 # watchdog that processes async requests on JEDI machines
0012 class AsyncRequestWatchDog(WatchDogBase):
0013     # constructor
0014     def __init__(self, taskBufferIF, ddmIF):
0015         WatchDogBase.__init__(self, taskBufferIF, ddmIF)
0016
0017     # main
0018     def doAction(self):
0019         tmpLog = MsgWrapper(logger)
0020         tmpLog.debug("start")
0021         try:
0022             processor.run(service_name="jedi", tbuf=self.taskBufferIF)
0023         except Exception as e:
0024             tmpLog.error(f"failed to process async requests with {e}")
0025             return self.SC_FAILED
0026         tmpLog.debug("done")
0027         return self.SC_SUCCEEDED