(client: redis.Redis)
| 303 | @pytest.mark.redismod |
| 304 | @skip_ifmodversion_lt("1.8.0", "timeseries") |
| 305 | def test_range_latest(client: redis.Redis): |
| 306 | timeseries = client.ts() |
| 307 | timeseries.create("t1") |
| 308 | timeseries.create("t2") |
| 309 | timeseries.createrule("t1", "t2", aggregation_type="sum", bucket_size_msec=10) |
| 310 | timeseries.add("t1", 1, 1) |
| 311 | timeseries.add("t1", 2, 3) |
| 312 | timeseries.add("t1", 11, 7) |
| 313 | timeseries.add("t1", 13, 1) |
| 314 | assert_resp_response( |
| 315 | client, |
| 316 | timeseries.range("t1", 0, 20), |
| 317 | [(1, 1.0), (2, 3.0), (11, 7.0), (13, 1.0)], |
| 318 | [[1, 1.0], [2, 3.0], [11, 7.0], [13, 1.0]], |
| 319 | ) |
| 320 | assert_resp_response(client, timeseries.range("t2", 0, 10), [(0, 4.0)], [[0, 4.0]]) |
| 321 | res = timeseries.range("t2", 0, 10, latest=True) |
| 322 | assert_resp_response(client, res, [(0, 4.0), (10, 8.0)], [[0, 4.0], [10, 8.0]]) |
| 323 | assert_resp_response( |
| 324 | client, timeseries.range("t2", 0, 9, latest=True), [(0, 4.0)], [[0, 4.0]] |
| 325 | ) |
| 326 | |
| 327 | |
| 328 | @pytest.mark.redismod |
nothing calls this directly
no test coverage detected