| 212 | |
| 213 | class TestRetryInterface(TestEndpointBase): |
| 214 | def setUp(self): |
| 215 | super().setUp() |
| 216 | self.retried_on_exception = None |
| 217 | self._operation = mock.Mock(spec=OperationModel) |
| 218 | self._operation.name = 'DescribeInstances' |
| 219 | self._operation.metadata = {'protocol': 'query'} |
| 220 | self._operation.service_model.service_id = ServiceId('EC2') |
| 221 | self._operation.has_streaming_output = False |
| 222 | self._operation.has_event_stream_output = False |
| 223 | |
| 224 | def assert_events_emitted(self, event_emitter, expected_events): |
| 225 | self.assertEqual( |