@@ -765,6 +765,7 @@ async def test_uncompressed(decoded_r: redis.Redis):
765
765
assert compressed_info ["memoryUsage" ] != uncompressed_info ["memoryUsage" ]
766
766
767
767
768
+ @pytest .mark .redismod
768
769
@skip_ifmodversion_lt ("1.12.0" , "timeseries" )
769
770
async def test_create_with_insertion_filters (decoded_r : redis .Redis ):
770
771
await decoded_r .ts ().create (
@@ -788,6 +789,7 @@ async def test_create_with_insertion_filters(decoded_r: redis.Redis):
788
789
)
789
790
790
791
792
+ @pytest .mark .redismod
791
793
@skip_ifmodversion_lt ("1.12.0" , "timeseries" )
792
794
async def test_alter_with_insertion_filters (decoded_r : redis .Redis ):
793
795
assert 1000 == await decoded_r .ts ().add ("time-series-1" , 1000 , 1.0 )
@@ -812,6 +814,7 @@ async def test_alter_with_insertion_filters(decoded_r: redis.Redis):
812
814
)
813
815
814
816
817
+ @pytest .mark .redismod
815
818
@skip_ifmodversion_lt ("1.12.0" , "timeseries" )
816
819
async def test_add_with_insertion_filters (decoded_r : redis .Redis ):
817
820
assert 1000 == await decoded_r .ts ().add (
@@ -829,6 +832,7 @@ async def test_add_with_insertion_filters(decoded_r: redis.Redis):
829
832
assert_resp_response (decoded_r , data_points , [(1000 , 1.0 )], [[1000 , 1.0 ]])
830
833
831
834
835
+ @pytest .mark .redismod
832
836
@skip_ifmodversion_lt ("1.12.0" , "timeseries" )
833
837
async def test_incrby_with_insertion_filters (decoded_r : redis .Redis ):
834
838
assert 1000 == await decoded_r .ts ().incrby (
@@ -851,6 +855,7 @@ async def test_incrby_with_insertion_filters(decoded_r: redis.Redis):
851
855
assert_resp_response (decoded_r , data_points , [(1000 , 11.1 )], [[1000 , 11.1 ]])
852
856
853
857
858
+ @pytest .mark .redismod
854
859
@skip_ifmodversion_lt ("1.12.0" , "timeseries" )
855
860
async def test_decrby_with_insertion_filters (decoded_r : redis .Redis ):
856
861
assert 1000 == await decoded_r .ts ().decrby (
0 commit comments