Searched refs:heartbeat_timeout (Results 1 – 2 of 2) 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)
22 heartbeat_timeout=None, argument63 if heartbeat_timeout is not None:64 attrs['heartbeatTimeout'] = heartbeat_timeout