| 89 | @skip_ifmodversion_lt("1.4.0", "timeseries") |
| 90 | @skip_if_server_version_lt("7.9.0") |
| 91 | async def test_alter_duplicate_policy(decoded_r: redis.Redis): |
| 92 | assert await decoded_r.ts().create(KEY1) |
| 93 | info = await decoded_r.ts().info(KEY1) |
| 94 | assert_resp_response( |
| 95 | decoded_r, "block", info.get("duplicate_policy"), info.get("duplicatePolicy") |
| 96 | ) |
| 97 | assert await decoded_r.ts().alter(KEY1, duplicate_policy="min") |
| 98 | info = await decoded_r.ts().info(KEY1) |
| 99 | assert_resp_response( |
| 100 | decoded_r, "min", info.get("duplicate_policy"), info.get("duplicatePolicy") |
| 101 | ) |
| 102 | |
| 103 | |
| 104 | @pytest.mark.redismod |