Matej Cepl
af3f271c65
OBS-URL: https://build.opensuse.org/package/show/devel:languages:python/python-redis?expand=0&rev=104
75 lines
2.8 KiB
Diff
75 lines
2.8 KiB
Diff
Index: python-redis/redis-5.2.1/tests/test_asyncio/test_scripting.py
|
|
===================================================================
|
|
--- python-redis.orig/redis-5.2.1/tests/test_asyncio/test_scripting.py
|
|
+++ python-redis/redis-5.2.1/tests/test_asyncio/test_scripting.py
|
|
@@ -28,14 +28,14 @@ class TestScripting:
|
|
yield redis
|
|
await redis.script_flush()
|
|
|
|
- @pytest.mark.asyncio(forbid_global_loop=True)
|
|
+ @pytest.mark.asyncio()
|
|
async def test_eval(self, r):
|
|
await r.flushdb()
|
|
await r.set("a", 2)
|
|
# 2 * 3 == 6
|
|
assert await r.eval(multiply_script, 1, "a", 3) == 6
|
|
|
|
- @pytest.mark.asyncio(forbid_global_loop=True)
|
|
+ @pytest.mark.asyncio()
|
|
@skip_if_server_version_lt("6.2.0")
|
|
async def test_script_flush(self, r):
|
|
await r.set("a", 2)
|
|
@@ -55,14 +55,14 @@ class TestScripting:
|
|
await r.script_load(multiply_script)
|
|
await r.script_flush("NOTREAL")
|
|
|
|
- @pytest.mark.asyncio(forbid_global_loop=True)
|
|
+ @pytest.mark.asyncio()
|
|
async def test_evalsha(self, r):
|
|
await r.set("a", 2)
|
|
sha = await r.script_load(multiply_script)
|
|
# 2 * 3 == 6
|
|
assert await r.evalsha(sha, 1, "a", 3) == 6
|
|
|
|
- @pytest.mark.asyncio(forbid_global_loop=True)
|
|
+ @pytest.mark.asyncio()
|
|
async def test_evalsha_script_not_loaded(self, r):
|
|
await r.set("a", 2)
|
|
sha = await r.script_load(multiply_script)
|
|
@@ -71,7 +71,7 @@ class TestScripting:
|
|
with pytest.raises(exceptions.NoScriptError):
|
|
await r.evalsha(sha, 1, "a", 3)
|
|
|
|
- @pytest.mark.asyncio(forbid_global_loop=True)
|
|
+ @pytest.mark.asyncio()
|
|
async def test_script_loading(self, r):
|
|
# get the sha, then clear the cache
|
|
sha = await r.script_load(multiply_script)
|
|
@@ -80,7 +80,7 @@ class TestScripting:
|
|
await r.script_load(multiply_script)
|
|
assert await r.script_exists(sha) == [True]
|
|
|
|
- @pytest.mark.asyncio(forbid_global_loop=True)
|
|
+ @pytest.mark.asyncio()
|
|
async def test_script_object(self, r):
|
|
await r.script_flush()
|
|
await r.set("a", 2)
|
|
@@ -97,7 +97,7 @@ class TestScripting:
|
|
# Test first evalsha block
|
|
assert await multiply(keys=["a"], args=[3]) == 6
|
|
|
|
- @pytest.mark.asyncio(forbid_global_loop=True)
|
|
+ @pytest.mark.asyncio()
|
|
async def test_script_object_in_pipeline(self, r):
|
|
await r.script_flush()
|
|
multiply = r.register_script(multiply_script)
|
|
@@ -127,7 +127,7 @@ class TestScripting:
|
|
assert await pipe.execute() == [True, b"2", 6]
|
|
assert await r.script_exists(multiply.sha) == [True]
|
|
|
|
- @pytest.mark.asyncio(forbid_global_loop=True)
|
|
+ @pytest.mark.asyncio()
|
|
async def test_eval_msgpack_pipeline_error_in_lua(self, r):
|
|
msgpack_hello = r.register_script(msgpack_hello_script)
|
|
assert msgpack_hello.sha
|