(client: redis.Redis)
| 509 | @pytest.mark.redismod |
| 510 | @skip_ifmodversion_lt("1.8.0", "timeseries") |
| 511 | def test_revrange_empty(client: redis.Redis): |
| 512 | timeseries = client.ts() |
| 513 | timeseries.create("t1") |
| 514 | timeseries.add("t1", 15, 1) |
| 515 | timeseries.add("t1", 17, 4) |
| 516 | timeseries.add("t1", 51, 3) |
| 517 | timeseries.add("t1", 73, 5) |
| 518 | timeseries.add("t1", 75, 3) |
| 519 | assert_resp_response( |
| 520 | client, |
| 521 | timeseries.revrange( |
| 522 | "t1", 0, 100, align=0, aggregation_type="max", bucket_size_msec=10 |
| 523 | ), |
| 524 | [(70, 5.0), (50, 3.0), (10, 4.0)], |
| 525 | [[70, 5.0], [50, 3.0], [10, 4.0]], |
| 526 | ) |
| 527 | res = timeseries.revrange( |
| 528 | "t1", 0, 100, align=0, aggregation_type="max", bucket_size_msec=10, empty=True |
| 529 | ) |
| 530 | for i in range(len(res)): |
| 531 | if math.isnan(res[i][1]): |
| 532 | res[i] = (res[i][0], None) |
| 533 | resp2_expected = [ |
| 534 | (70, 5.0), |
| 535 | (60, None), |
| 536 | (50, 3.0), |
| 537 | (40, None), |
| 538 | (30, None), |
| 539 | (20, None), |
| 540 | (10, 4.0), |
| 541 | ] |
| 542 | resp3_expected = [ |
| 543 | [70, 5.0], |
| 544 | (60, None), |
| 545 | [50, 3.0], |
| 546 | (40, None), |
| 547 | (30, None), |
| 548 | (20, None), |
| 549 | [10, 4.0], |
| 550 | ] |
| 551 | assert_resp_response(client, res, resp2_expected, resp3_expected) |
| 552 | |
| 553 | |
| 554 | @pytest.mark.onlynoncluster |
nothing calls this directly
no test coverage detected