(payload_encoded: str)
| 444 | |
| 445 | def _create_request_processor(self): |
| 446 | async def inner(payload_encoded: str) -> web.Response: |
| 447 | id = unsafe_make_pointer(uuid4().int) |
| 448 | payload = json.loads(payload_encoded) |
| 449 | self._cast_types_to_schema(payload) |
| 450 | event = asyncio.Event() |
| 451 | |
| 452 | self._tasks[id] = { |
| 453 | "event": event, |
| 454 | "result": "-PENDING-", |
| 455 | } |
| 456 | |
| 457 | self._add_inner(id, payload) |
| 458 | response = await self._fetch_response(id, event) |
| 459 | if self._delete_completed_queries: |
| 460 | self._remove_inner(id, payload) |
| 461 | return self._process_response(response) |
| 462 | |
| 463 | if not self._cache_strategy: |
| 464 | return inner |
nothing calls this directly
no test coverage detected