(self, request, operation_model, context)
| 229 | return success_response |
| 230 | |
| 231 | def _get_response(self, request, operation_model, context): |
| 232 | # This will return a tuple of (success_response, exception) |
| 233 | # and success_response is itself a tuple of |
| 234 | # (http_response, parsed_dict). |
| 235 | # If an exception occurs then the success_response is None. |
| 236 | # If no exception occurs then exception is None. |
| 237 | success_response, exception = self._do_get_response( |
| 238 | request, operation_model, context |
| 239 | ) |
| 240 | kwargs_to_emit = { |
| 241 | 'response_dict': None, |
| 242 | 'parsed_response': None, |
| 243 | 'context': context, |
| 244 | 'exception': exception, |
| 245 | } |
| 246 | if success_response is not None: |
| 247 | http_response, parsed_response = success_response |
| 248 | kwargs_to_emit['parsed_response'] = parsed_response |
| 249 | kwargs_to_emit['response_dict'] = convert_to_response_dict( |
| 250 | http_response, operation_model |
| 251 | ) |
| 252 | service_id = operation_model.service_model.service_id.hyphenize() |
| 253 | self._event_emitter.emit( |
| 254 | f'response-received.{service_id}.{operation_model.name}', |
| 255 | **kwargs_to_emit, |
| 256 | ) |
| 257 | return success_response, exception |
| 258 | |
| 259 | def _do_get_response(self, request, operation_model, context): |
| 260 | try: |
no test coverage detected