diff options
| author | sideshowdave7 | 2017-01-16 14:31:33 -0700 |
|---|---|---|
| committer | sideshowdave7 | 2017-01-16 14:31:33 -0700 |
| commit | 99d65769f55ca3a0821bc590fc5274e5dfd798bc (patch) | |
| tree | 4d43de104dbc2694bdd62038c6532c27a32df75e | |
| parent | a4a561499b70480c47ca622da7616c8d1860c806 (diff) | |
| download | eventmq-99d65769f55ca3a0821bc590fc5274e5dfd798bc.tar.gz eventmq-99d65769f55ca3a0821bc590fc5274e5dfd798bc.zip | |
delete the job storage on unschedule
| -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: |