check_hung_workers

check_hung_workers(watchdog_registry)

Check that all workers have reported in time.

• Call in the master process regularly.

Raises:

WatchedProcessDidNotReport – If any of the watched processes has failed to report in time.

Parameters:

watchdog_registry (multiprocessing.managers.DictProxy | dict) –