diff options
| author | Laurel-rao <42195541+Laurel-rao@users.noreply.github.com> | 2020-04-21 16:56:05 +0800 |
|---|---|---|
| committer | Alex Grönholm <alex.gronholm@nextday.fi> | 2020-04-22 12:57:41 +0300 |
| commit | c54657f34aaa72c1c3a0b815c63fd682f2d7dc41 (patch) | |
| tree | 6093f881a2009a489d87f363383fd5c2f92fd028 | |
| parent | 204a74074b2a5ad27954799cc4926f5874e3e9b0 (diff) | |
| download | apscheduler-c54657f34aaa72c1c3a0b815c63fd682f2d7dc41.tar.gz | |
Fix zookeeper plugin Bug on windows
function "os.path.join" return "\" on windows, it can't work on zookeeper
replace os.path.join to "/", make apscheduler to support windows
| -rw-r--r-- | apscheduler/jobstores/zookeeper.py | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/apscheduler/jobstores/zookeeper.py b/apscheduler/jobstores/zookeeper.py index 2cca83e..5253069 100644 --- a/apscheduler/jobstores/zookeeper.py +++ b/apscheduler/jobstores/zookeeper.py @@ -1,6 +1,5 @@ from __future__ import absolute_import -import os from datetime import datetime from pytz import utc @@ -65,7 +64,7 @@ class ZooKeeperJobStore(BaseJobStore): def lookup_job(self, job_id): self._ensure_paths() - node_path = os.path.join(self.path, job_id) + node_path = self.path + "/" + str(job_id) try: content, _ = self.client.get(node_path) doc = pickle.loads(content) @@ -92,7 +91,7 @@ class ZooKeeperJobStore(BaseJobStore): def add_job(self, job): self._ensure_paths() - node_path = os.path.join(self.path, str(job.id)) + node_path = self.path + "/" + str(job.id) value = { 'next_run_time': datetime_to_utc_timestamp(job.next_run_time), 'job_state': job.__getstate__() @@ -105,7 +104,7 @@ class ZooKeeperJobStore(BaseJobStore): def update_job(self, job): self._ensure_paths() - node_path = os.path.join(self.path, str(job.id)) + node_path = self.path + "/" + str(job.id) changes = { 'next_run_time': datetime_to_utc_timestamp(job.next_run_time), 'job_state': job.__getstate__() @@ -118,7 +117,7 @@ class ZooKeeperJobStore(BaseJobStore): def remove_job(self, job_id): self._ensure_paths() - node_path = os.path.join(self.path, str(job_id)) + node_path = self.path + "/" + str(job_id) try: self.client.delete(node_path) except NoNodeError: @@ -151,7 +150,7 @@ class ZooKeeperJobStore(BaseJobStore): all_ids = self.client.get_children(self.path) for node_name in all_ids: try: - node_path = os.path.join(self.path, node_name) + node_path = self.path + "/" + node_name content, _ = self.client.get(node_path) doc = pickle.loads(content) job_def = { |