修复mq消息消费

services/pipeline.py

@@ -172,6 +172,9 @@ class PiaoQuanPipeline:
                             account=self.account
                         )
                         return flag
+            else:
+                continue
+        return True
 
     async def repeat_video(self) -> bool:
         out_id = self.item.get("out_video_id")