diff options
Diffstat (limited to 'tests/test_asyncio/test_bloom.py')
| -rw-r--r-- | tests/test_asyncio/test_bloom.py | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/tests/test_asyncio/test_bloom.py b/tests/test_asyncio/test_bloom.py index fe3bd76..15b22b3 100644 --- a/tests/test_asyncio/test_bloom.py +++ b/tests/test_asyncio/test_bloom.py @@ -393,6 +393,19 @@ async def test_tdigest_cdf(modclient: redis.Redis): assert 0.9 == round(await modclient.tdigest().cdf("tDigest", 9.0), 1) +@pytest.mark.redismod +@pytest.mark.experimental +@skip_ifmodversion_lt("2.4.0", "bf") +async def test_tdigest_mergestore(modclient: redis.Redis): + assert await modclient.tdigest().create("sourcekey1", 100) + assert await modclient.tdigest().create("sourcekey2", 100) + assert await modclient.tdigest().add("sourcekey1", [10], [1.0]) + assert await modclient.tdigest().add("sourcekey2", [50], [1.0]) + assert await modclient.tdigest().mergestore("dest", 2, "sourcekey1", "sourcekey2") + assert await modclient.tdigest().max("dest") == 50 + assert await modclient.tdigest().min("dest") == 10 + + # @pytest.mark.redismod # async def test_pipeline(modclient: redis.Redis): # pipeline = await modclient.bf().pipeline() |