async def METHOD_NAME(self):
    session = InMemoryProfile.test_session()
    with async_mock.patch.object(
        V20DiscoveryExchangeRecord,
        "retrieve_by_tag_filter",
        async_mock.CoroutineMock(),
    ) as mock_retrieve_by_tag_filter:
        mock_retrieve_by_tag_filter.side_effect = StorageNotFoundError
        check = await V20DiscoveryExchangeRecord.exists_for_connection_id(
            session=session, connection_id="test123"
        )
        assert not check