From 26c3879b5ce8f9ea1c5c1a19187793c752f3784e Mon Sep 17 00:00:00 2001 From: vapao Date: Mon, 5 Jul 2021 19:28:24 +0800 Subject: [PATCH] fix issues --- spug_api/apps/exec/management/commands/runworker.py | 1 + 1 file changed, 1 insertion(+) diff --git a/spug_api/apps/exec/management/commands/runworker.py b/spug_api/apps/exec/management/commands/runworker.py index 134c26f..87591e3 100644 --- a/spug_api/apps/exec/management/commands/runworker.py +++ b/spug_api/apps/exec/management/commands/runworker.py @@ -24,6 +24,7 @@ class Worker: def run(self): logging.warning('Running worker') + self.rds.delete(EXEC_WORKER_KEY, MONITOR_WORKER_KEY, SCHEDULE_WORKER_KEY) while True: key, job = self.rds.blpop([EXEC_WORKER_KEY, SCHEDULE_WORKER_KEY, MONITOR_WORKER_KEY]) key = key.decode()