Fix None if lag is None (#27)

b-scheduler · Aug 12, 2024 · 978ee1d · 978ee1d
1 parent 38a3b04
commit 978ee1d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/brq/operator.py b/brq/operator.py
@@ -209,7 +209,9 @@ async def count_unprocessed_jobs(
         gropu_infos = await self.redis.xinfo_groups(stream_name)
         for group_info in gropu_infos:
             if group_info["name"] == group_name:
-                return group_info["pending"] + group_info.get("lag", 0)
+                lag = group_info.get("lag") or 0
+                pending = group_info.get("pending") or 0
+                return lag + pending
         return await self.count_stream(function_name)
 
     async def count_dead_messages(self, function_name: str) -> int: