(client: redis.Redis)
| 1001 | @pytest.mark.redismod |
| 1002 | @skip_ifmodversion_lt("1.8.0", "timeseries") |
| 1003 | def test_mget_latest(client: redis.Redis): |
| 1004 | timeseries = client.ts() |
| 1005 | timeseries.create("t1") |
| 1006 | timeseries.create("t2", labels={"is_compaction": "true"}) |
| 1007 | timeseries.createrule("t1", "t2", aggregation_type="sum", bucket_size_msec=10) |
| 1008 | timeseries.add("t1", 1, 1) |
| 1009 | timeseries.add("t1", 2, 3) |
| 1010 | timeseries.add("t1", 11, 7) |
| 1011 | timeseries.add("t1", 13, 1) |
| 1012 | res = timeseries.mget(filters=["is_compaction=true"]) |
| 1013 | assert_resp_response(client, res, [{"t2": [{}, 0, 4.0]}], {"t2": [{}, [0, 4.0]]}) |
| 1014 | res = timeseries.mget(filters=["is_compaction=true"], latest=True) |
| 1015 | assert_resp_response(client, res, [{"t2": [{}, 10, 8.0]}], {"t2": [{}, [10, 8.0]]}) |
| 1016 | |
| 1017 | |
| 1018 | @pytest.mark.redismod |
nothing calls this directly
no test coverage detected