diff --git a/src/messages.py b/src/messages.py
index ae3f4ea..e990691 100644
--- a/src/messages.py
+++ b/src/messages.py
@@ -139,7 +139,8 @@ async def __call__(self):
             results = await asyncio.gather(*rating_tasks)
 
             for i, result in enumerate(results):
-                total += 1
+                total += 1             
+
                 if result == None:
                     continue
 
@@ -153,7 +154,8 @@ async def __call__(self):
                 is_last = (done == self.shift) or (total == len(self.messages))
                 await job(is_last)
 
+                if is_last:
+                    self.__pending__()
+                    return
 
-        self.__pending__()
-        return