test hdel_many

tests/test_backend.py

@@ -836,6 +836,18 @@ def test_hdel(self, cache: ValkeyCache):
         assert not cache.hexists("foo_hash2", "foo1")
         assert cache.hexists("foo_hash2", "foo2")
 
+    def test_hdel_many(self, cache: ValkeyCache):
+        if isinstance(cache.client, ShardClient):
+            pytest.skip("ShardClient doesn't support get_client")
+        cache.hset("foo_hash3", "foo1", "bar1")
+        cache.hset("foo_hash3", "foo2", "bar2")
+        assert cache.hlen("foo_hash3") == 2
+        deleted_count = cache.hdel_many("foo_hash3", ["foo1", "foo2"])
+        assert deleted_count == 2
+        assert cache.hlen("foo_hash3") == 0
+        assert not cache.hexists("foo_hash3", "foo1")
+        assert not cache.hexists("foo_hash3", "foo2")
+
     def test_hlen(self, cache: ValkeyCache):
         if isinstance(cache.client, ShardClient):
             pytest.skip("ShardClient doesn't support get_client")

tests/tests_async/test_backend.py

@@ -864,6 +864,16 @@ async def test_hdel(self, cache: AsyncValkeyCache):
         assert not await cache.ahexists("foo_hash2", "foo1")
         assert await cache.ahexists("foo_hash2", "foo2")
 
+    async def test_hdel_many(self, cache: AsyncValkeyCache):
+        await cache.ahset("foo_hash3", "foo1", "bar1")
+        await cache.ahset("foo_hash3", "foo2", "bar2")
+        assert await cache.ahlen("foo_hash3") == 2
+        deleted_count = await cache.ahdel_many("foo_hash3", ["foo1", "foo2"])
+        assert deleted_count == 2
+        assert await cache.ahlen("foo_hash3") == 0
+        assert not await cache.ahexists("foo_hash3", "foo1")
+        assert not await cache.ahexists("foo_hash3", "foo2")
+
     async def test_hlen(self, cache: AsyncValkeyCache):
         # if isinstance(cache.client, ShardClient):
         #     pytest.skip("ShardClient doesn't support get_client")