message: Increase the ping timeout from 5 seconds to a minute. This gives a bit more breathing room in case the workers somehow become unresponsive .
diff: @@ -106,7 +106,7 @@ class WorkerHeartbeatManager(object):
  self._session.run(self._ops,
  {self._request_placeholder: message.SerializeToString()})
  - def ping(self, request=None, timeout_in_ms=5000):
  + def ping(self, request=None, timeout_in_ms=60000):
  """Ping all workers, returning the parsed status results."""
  if request is None:
  request = event_pb2.WorkerHeartbeatRequest()
  