Searched refs:run_on_all_workers (Results 1 – 3 of 3) sorted by relevance
68 def __init__(self, run_on_all_workers): argument70 self._run_on_all_workers = run_on_all_workers75 def run_on_all_workers(self): member in _BaseMonitorWrapper
86 def run_on_all_workers(self): member in BaseMonitor415 def run_on_all_workers(self): member in StopAtStep1341 m for m in deprecated_monitors if m.run_on_all_workers
294 monitors = [monitor for monitor in monitors if monitor.run_on_all_workers]