diff options
| -rw-r--r-- | eventmq/scheduler.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/eventmq/scheduler.py b/eventmq/scheduler.py index 9130694..a2266d4 100644 --- a/eventmq/scheduler.py +++ b/eventmq/scheduler.py | |||
| @@ -304,6 +304,7 @@ class Scheduler(HeartbeatMixin, EMQPService): | |||
| 304 | # in memory | 304 | # in memory |
| 305 | try: | 305 | try: |
| 306 | if (self.redis_server.get(schedule_hash)): | 306 | if (self.redis_server.get(schedule_hash)): |
| 307 | self.redis_server.delete(schedule_hash) | ||
| 307 | self.redis_server.lrem('interval_jobs', 0, schedule_hash) | 308 | self.redis_server.lrem('interval_jobs', 0, schedule_hash) |
| 308 | self.redis_server.save() | 309 | self.redis_server.save() |
| 309 | except redis.ConnectionError: | 310 | except redis.ConnectionError: |