storage append on non-empty msg list

basis-company · Sep 19, 2023 · 069e731 · 069e731
1 parent d9095f5
commit 069e731
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/sharded_queue/__init__.py b/sharded_queue/__init__.py
@@ -110,7 +110,7 @@ async def register(
             )
 
         for pipe in set([pipe for (pipe, _) in pipe_messages]):
-            await self.storage.append(pipe, *[
+            msgs = [
                 msg for msg in
                 [
                     self.serializer.serialize(request)
@@ -119,7 +119,9 @@ async def register(
                 ]
                 if not if_not_exists
                 or not await self.storage.contains(pipe, msg)
-            ])
+            ]
+            if len(msgs):
+                await self.storage.append(pipe, *msgs)
 
 
 @dataclass