F 修复执行发布可能意外报错的问题

Author: vapao

spug_api/consumer/consumers.py

@@ -32,7 +32,8 @@ def get_response(self):
         if self.log_key:
             return self.rds.brpoplpush(self.token, self.log_key, timeout=5)
         else:
-            return self.rds.brpop(self.token, timeout=5)[1]
+            response = self.rds.brpop(self.token, timeout=5)
+            return response[1] if response else None
 
     def receive(self, **kwargs):
         response = self.get_response()