async def METHOD_NAME(self):
    session = InMemoryProfile.test_session()
    record = V20DiscoveryExchangeRecord(
        queries_msg=Queries(
            queries=[
                QueryItem(feature_type="protocol", match="*"),
                QueryItem(feature_type="goal-code", match="test"),
            ],
        ),
        connection_id="test123",
    )
    await record.save(session)
    retrieved = await V20DiscoveryExchangeRecord.retrieve_by_connection_id(
        session=session, connection_id="test123"
    )
    assert retrieved
    assert retrieved.connection_id == "test123"