def transient_failure(self, a, b):
    self.calls += 1
    if self.calls > 8:
      return a + b
    raise NotImplementedError
dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/utils/retry_test.py/RetryTest.transient_failure/original