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()