Searched refs:heartbeat_timeout (Results 1 – 1 of 1) sorted by relevance
104 def __init__(self, num_workers, heartbeat_timeout=1): argument118 self.heartbeat_timeout = heartbeat_timeout275 result = self.done_queue.get(timeout=self.heartbeat_timeout)