bug fix

Author: amirreza8002

django_valkey/async_cache/client/default.py

@@ -468,11 +468,19 @@ async def get_many(
         try:
             pipline = await client.pipeline()
             for key in keys:
-                await self.aget(key=key, version=version, client=pipline)
-            await pipline.execute()
+                key = await self.make_key(key, version=version)
+                await pipline.get(key)
+            values = await pipline.execute()
         except _main_exceptions as e:
             raise ConnectionInterrupted(connection=client) from e
 
+        recovered_data = {}
+        for key, value in zip(keys, values):
+            if not value:
+                continue
+            recovered_data[key] = await self.decode(value)
+        return recovered_data
+
     aget_many = get_many
 
     async def set_many(

django_valkey/base_client.py

@@ -591,7 +591,7 @@ def get_many(
         keys: Iterable[KeyT],
         version: int | None = None,
         client: Backend | None = None,
-    ):
+    ) -> dict:
         """
         non-atomic bulk method.
         get values of the provided keys
@@ -601,12 +601,20 @@ def get_many(
         try:
             pipeline = client.pipeline()
             for key in keys:
-                self.get(key=key, version=version, client=pipeline)
-            pipeline.execute()
+                key = self.make_key(key, version=version)
+                pipeline.get(key)
+            values = pipeline.execute()
 
         except _main_exceptions as e:
             raise ConnectionInterrupted(connection=client) from e
 
+        recovered_data = {}
+        for key, value in zip(keys, values):
+            if not value:
+                continue
+            recovered_data[key] = self.decode(value)
+        return recovered_data
+
     def set_many(
         self,
         data: Dict[KeyT, EncodableT],