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

fix issues

pull/342/head
vapao 2021-07-05 19:28:24 +08:00
parent 018ada226e
commit 26c3879b5c
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
spug_api/apps/exec/management/commands/runworker.py
View File

@ -24,6 +24,7 @@ class Worker:
def run(self): def run(self):
logging.warning('Running worker') logging.warning('Running worker')
self.rds.delete(EXEC_WORKER_KEY, MONITOR_WORKER_KEY, SCHEDULE_WORKER_KEY)
while True: while True:
key, job = self.rds.blpop([EXEC_WORKER_KEY, SCHEDULE_WORKER_KEY, MONITOR_WORKER_KEY]) key, job = self.rds.blpop([EXEC_WORKER_KEY, SCHEDULE_WORKER_KEY, MONITOR_WORKER_KEY])
key = key.decode() key = key.decode()