@pytest.mark.asyncio
async def test_add_existing(self, redis, redis_connection):
    redis_connection.set.return_value = False
    with pytest.raises(ValueError):
        (await redis._add(Keys.KEY, 'value'))
@pytest.mark.asyncio
async def test_add_existing(self, redis, redis_connection):
    redis_connection.set.return_value = False
    with pytest.raises(ValueError):
        (await redis._add(Keys.KEY, 'value'))