Function test_rev_range

tests/test_asyncio/test_timeseries.py:325–364

(decoded_r: redis.Redis)

@pytest.mark.redismod
@skip_ifmodversion_lt("1.10.0", "timeseries")
async def test_rev_range(decoded_r: redis.Redis):
    for i in range(100):
        await decoded_r.ts().add(KEY1, i, i % 7)
    assert 100 == len(await decoded_r.ts().range(KEY1, 0, 200))
    for i in range(100):
        await decoded_r.ts().add(KEY1, i + 200, i % 7)
    assert 200 == len(await decoded_r.ts().range(KEY1, 0, 500))
    # first sample isn't returned
    assert 20 == len(
        await decoded_r.ts().revrange(
            KEY1, 0, 500, aggregation_type="avg", bucket_size_msec=10
        )
    )
    assert 10 == len(await decoded_r.ts().revrange(KEY1, 0, 500, count=10))
    assert 2 == len(
        await decoded_r.ts().revrange(
            KEY1,
            0,
            500,
            filter_by_ts=[i for i in range(10, 20)],
            filter_by_min_value=1,
            filter_by_max_value=2,
        )
    )
    assert_resp_response(
        decoded_r,
        await decoded_r.ts().revrange(
            KEY1, 0, 10, aggregation_type="count", bucket_size_msec=10, align="+"
        ),
        [(10, 1.0), (0, 10.0)],
        [[10, 1.0], [0, 10.0]],
    )
    assert_resp_response(
        decoded_r,
        await decoded_r.ts().revrange(
            KEY1, 0, 10, aggregation_type="count", bucket_size_msec=10, align=1
        ),
        [(1, 10.0), (0, 1.0)],
        [[1, 10.0], [0, 1.0]],
    )


@pytest.mark.onlynoncluster