diff options
| author | Selwin Ong <selwin.ong@gmail.com> | 2020-10-20 07:12:31 +0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-10-20 07:12:31 +0700 |
| commit | df14acaf02add78a828c4acb7c97db1dc537c6f5 (patch) | |
| tree | fbde50abc4fe332f926f64206b9cc296524039d0 | |
| parent | 2da957a68da218db0ecc75786d66c2128cff400e (diff) | |
| download | rq-df14acaf02add78a828c4acb7c97db1dc537c6f5.tar.gz | |
Increase scheduler lock TTL to 60 (#1362)
| -rw-r--r-- | rq/scheduler.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/rq/scheduler.py b/rq/scheduler.py index 4d84b48..1be2e29 100644 --- a/rq/scheduler.py +++ b/rq/scheduler.py @@ -85,7 +85,7 @@ class RQScheduler(object): pid = os.getpid() logger.info("Trying to acquire locks for %s", ", ".join(self._queue_names)) for name in self._queue_names: - if self.connection.set(self.get_locking_key(name), pid, nx=True, ex=5): + if self.connection.set(self.get_locking_key(name), pid, nx=True, ex=60): successful_locks.add(name) # Always reset _scheduled_job_registries when acquiring locks |