Function test_multi_reverse_range

tests/test_asyncio/test_timeseries.py:581–776

(decoded_r: redis.Redis)

@pytest.mark.redismod
@skip_ifmodversion_lt("1.10.0", "timeseries")
async def test_multi_reverse_range(decoded_r: redis.Redis):
    await decoded_r.ts().create(KEY1, labels={"Test": "This", "team": "ny"})
    await decoded_r.ts().create(
        KEY2, labels={"Test": "This", "Taste": "That", "team": "sf"}
    )
    for i in range(100):
        await decoded_r.ts().add(KEY1, i, i % 7)
        await decoded_r.ts().add(KEY2, i, i % 11)

    # ``expected_response_shape`` is ``"unified"`` for
    # ``legacy_responses=False`` (any protocol) and ``"legacy_resp3"`` for
    # ``protocol=3`` with ``legacy_responses=True``. The unified shape
    # always emits ``[labels, [], samples]`` (samples at index 2); legacy
    # RESP3 preserves the wire layout, appending an extra ``sources``
    # element under GROUPBY which pushes samples to index 3.
    groupby_samples_idx = 2 if expected_response_shape(decoded_r) == "unified" else 3

    res = await decoded_r.ts().mrange(0, 200, filters=["Test=This"])
    assert res is not None
    assert 2 == len(res)
    if expects_resp2_shape(decoded_r):
        assert 100 == len(res[0][KEY1][1])

        res = await decoded_r.ts().mrange(0, 200, filters=["Test=This"], count=10)
        assert res is not None
        assert 10 == len(res[0][KEY1][1])

        for i in range(100):
            await decoded_r.ts().add(KEY1, i + 200, i % 7)
        res = await decoded_r.ts().mrevrange(
            0, 500, filters=["Test=This"], aggregation_type="avg", bucket_size_msec=10
        )
        assert res is not None
        assert 2 == len(res)
        assert 20 == len(res[0][KEY1][1])
        assert {} == res[0][KEY1][0]

        # test withlabels
        res = await decoded_r.ts().mrevrange(
            0, 200, filters=["Test=This"], with_labels=True
        )
        assert res is not None
        assert {"Test": "This", "team": "ny"} == res[0][KEY1][0]

        # test with selected labels
        res = await decoded_r.ts().mrevrange(
            0, 200, filters=["Test=This"], select_labels=["team"]
        )
        assert res is not None
        assert {"team": "ny"} == res[0][KEY1][0]
        assert {"team": "sf"} == res[1][KEY2][0]

        # test filterby
        res = await decoded_r.ts().mrevrange(
            0,
            200,
            filters=["Test=This"],
            filter_by_ts=[i for i in range(10, 20)],