def WaitUntil(self, condition_cb, timeout=5):
    """Wait a fixed time until the condition is true."""
    for _ in xrange(int(self.sleep_time / timeout)):
      res = condition_cb()
      if res:
        return res

      time.sleep(self.sleep_time)

    raise RuntimeError("Timeout exceeded. Condition not true")
dataset/ETHPy150Open google/grr/grr/lib/threadpool_test.py/ThreadPoolTest.WaitUntil/swapped operands of `/`