Searched refs:heartbeat_timeout (Results 1 – 1 of 1) sorted by relevance
76 def __init__(self, num_workers, heartbeat_timeout=30): argument92 self.heartbeat_timeout = heartbeat_timeout130 result = self.done_queue.get(timeout=self.heartbeat_timeout)