@pytest.mark.asyncio
async def test_conn(self, redis, redis_connection, mocker):
    mocker.spy(self, 'dummy')
    d = conn(self.dummy)
    (await d(redis, 'a', _conn=None))
    self.dummy.assert_called_with(redis, 'a', _conn=redis_connection)
@pytest.mark.asyncio
async def test_conn(self, redis, redis_connection, mocker):
    mocker.spy(self, 'dummy')
    d = conn(self.dummy)
    (await d(redis, 'a', _conn=None))
    self.dummy.assert_called_with(redis, 'a', _conn=redis_connection)