mark_alive#

mark_alive(watchdog_registry, name, time_=None)[source]#

Mark the worker being alive.

Call for each registered worker at the end of its duty cycle.

Parameters:
  • watchdog_registry (multiprocessing.managers.DictProxy | dict) –

  • name (str) –

  • time_ (Optional[float]) –