def testBrokenFlow(self):
    client_mock = action_mocks.ActionMock("ReadBuffer")
    with self.assertRaises(RuntimeError):
      for _ in test_lib.TestFlowHelper(
          "BrokenFlow", client_mock, client_id=self.client_id,
          check_flow_errors=True, token=self.token):
        pass
Check that flows which call to incorrect states raise.
dataset/ETHPy150Open google/grr/grr/lib/flow_test.py/FlowTest.testBrokenFlow