Method _fetch_response

python/pathway/io/http/_server.py:468–471

(self, id, event)

        return self._cache_strategy.wrap_async(inner)

    async def _fetch_response(self, id, event) -> Any:
        await event.wait()
        task = self._tasks.pop(id)
        return task["result"]

    def _cast_types_to_schema(self, payload: dict):
        dtypes = self._schema._dtypes()