async def METHOD_NAME(self):
    session = InMemoryProfile.test_session()
    record = V10DiscoveryExchangeRecord(
        query_msg=Query(query="*"), connection_id="test123"
    )
    await record.save(session)
    retrieved = await V10DiscoveryExchangeRecord.retrieve_by_connection_id(
        session=session, connection_id="test123"
    )
    assert retrieved
    assert retrieved.connection_id == "test123"