@@ -28,14 +28,12 @@ async def r(self, create_valkey):
2828 yield valkey
2929 await valkey .script_flush ()
3030
31- @pytest .mark .asyncio (forbid_global_loop = True )
3231 async def test_eval (self , r ):
3332 await r .flushdb ()
3433 await r .set ("a" , 2 )
3534 # 2 * 3 == 6
3635 assert await r .eval (multiply_script , 1 , "a" , 3 ) == 6
3736
38- @pytest .mark .asyncio (forbid_global_loop = True )
3937 @skip_if_server_version_lt ("6.2.0" )
4038 async def test_script_flush (self , r ):
4139 await r .set ("a" , 2 )
@@ -55,14 +53,12 @@ async def test_script_flush(self, r):
5553 await r .script_load (multiply_script )
5654 await r .script_flush ("NOTREAL" )
5755
58- @pytest .mark .asyncio (forbid_global_loop = True )
5956 async def test_evalsha (self , r ):
6057 await r .set ("a" , 2 )
6158 sha = await r .script_load (multiply_script )
6259 # 2 * 3 == 6
6360 assert await r .evalsha (sha , 1 , "a" , 3 ) == 6
6461
65- @pytest .mark .asyncio (forbid_global_loop = True )
6662 async def test_evalsha_script_not_loaded (self , r ):
6763 await r .set ("a" , 2 )
6864 sha = await r .script_load (multiply_script )
@@ -71,7 +67,6 @@ async def test_evalsha_script_not_loaded(self, r):
7167 with pytest .raises (exceptions .NoScriptError ):
7268 await r .evalsha (sha , 1 , "a" , 3 )
7369
74- @pytest .mark .asyncio (forbid_global_loop = True )
7570 async def test_script_loading (self , r ):
7671 # get the sha, then clear the cache
7772 sha = await r .script_load (multiply_script )
@@ -80,7 +75,6 @@ async def test_script_loading(self, r):
8075 await r .script_load (multiply_script )
8176 assert await r .script_exists (sha ) == [True ]
8277
83- @pytest .mark .asyncio (forbid_global_loop = True )
8478 async def test_script_object (self , r ):
8579 await r .script_flush ()
8680 await r .set ("a" , 2 )
@@ -97,7 +91,6 @@ async def test_script_object(self, r):
9791 # Test first evalsha block
9892 assert await multiply (keys = ["a" ], args = [3 ]) == 6
9993
100- @pytest .mark .asyncio (forbid_global_loop = True )
10194 async def test_script_object_in_pipeline (self , r ):
10295 await r .script_flush ()
10396 multiply = r .register_script (multiply_script )
@@ -127,7 +120,6 @@ async def test_script_object_in_pipeline(self, r):
127120 assert await pipe .execute () == [True , b"2" , 6 ]
128121 assert await r .script_exists (multiply .sha ) == [True ]
129122
130- @pytest .mark .asyncio (forbid_global_loop = True )
131123 async def test_eval_msgpack_pipeline_error_in_lua (self , r ):
132124 msgpack_hello = r .register_script (msgpack_hello_script )
133125 assert msgpack_hello .sha
0 commit comments