diff options
Diffstat (limited to 'apscheduler/jobstores/mongodb.py')
| -rw-r--r-- | apscheduler/jobstores/mongodb.py | 11 |
1 files changed, 3 insertions, 8 deletions
diff --git a/apscheduler/jobstores/mongodb.py b/apscheduler/jobstores/mongodb.py index 7dbc3b1..bb06ade 100644 --- a/apscheduler/jobstores/mongodb.py +++ b/apscheduler/jobstores/mongodb.py @@ -1,4 +1,4 @@ -from __future__ import absolute_import +import pickle import warnings from apscheduler.jobstores.base import BaseJobStore, JobLookupError, ConflictingIdError @@ -6,11 +6,6 @@ from apscheduler.util import maybe_ref, datetime_to_utc_timestamp, utc_timestamp from apscheduler.job import Job try: - import cPickle as pickle -except ImportError: # pragma: nocover - import pickle - -try: from bson.binary import Binary from pymongo.errors import DuplicateKeyError from pymongo import MongoClient, ASCENDING @@ -36,7 +31,7 @@ class MongoDBJobStore(BaseJobStore): def __init__(self, database='apscheduler', collection='jobs', client=None, pickle_protocol=pickle.HIGHEST_PROTOCOL, **connect_args): - super(MongoDBJobStore, self).__init__() + super().__init__() self.pickle_protocol = pickle_protocol if not database: @@ -53,7 +48,7 @@ class MongoDBJobStore(BaseJobStore): self.collection = self.client[database][collection] def start(self, scheduler, alias): - super(MongoDBJobStore, self).start(scheduler, alias) + super().start(scheduler, alias) self.collection.ensure_index('next_run_time', sparse=True) @property |