async def METHOD_NAME(self):
    self.request.json = async_mock.CoroutineMock()
    self.request.query = {"connection_id": "test"}
    test_rec = V10DiscoveryExchangeRecord(
        discovery_exchange_id="3fa85f64-5717-4562-b3fc-2c963f66afa6",
        query_msg=Query(query="*"),
    )
    with async_mock.patch.object(
        test_module.web, "json_response"
    ) as mock_response, async_mock.patch.object(
        test_module, "V10DiscoveryExchangeRecord", autospec=True
    ) as mock_ex_rec:
        mock_ex_rec.retrieve_by_connection_id.return_value = test_rec
        res = await test_module.query_records(self.request)
        mock_response.assert_called_once_with({"results": [test_rec.serialize()]})