github
/
spug
mirror of https://github.com/openspug/spug
1
0
Fork 0
Code Issues Releases Wiki Activity

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

pull/59/head v2.2.0
vapao 2020-03-20 16:35:45 +08:00
parent 65856104c1
commit a5a763de98
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
spug_api/consumer/consumers.py
View File

@ -32,7 +32,8 @@ class ExecConsumer(WebsocketConsumer):
if self.log_key: if self.log_key:
return self.rds.brpoplpush(self.token, self.log_key, timeout=5) return self.rds.brpoplpush(self.token, self.log_key, timeout=5)
else: 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): def receive(self, **kwargs):
response = self.get_response() response = self.get_response()