check_hung_workers#

API documentation for tradeexecutor.cli.watchdog.check_hung_workers Python function.

check_hung_workers(watchdog_registry)[source]#

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) –