summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlex Grönholm <alex.gronholm@nextday.fi>2022-02-09 11:34:57 +0200
committerAlex Grönholm <alex.gronholm@nextday.fi>2022-02-09 11:34:57 +0200
commit26eefbbb5c40118887cd84ed4391356971e94135 (patch)
tree4e70e540f8eb5de4fe2ad8deb41ccd74f39cde64
parent4ded0dceb05acc95b8ef14cfe397e91391a5d39a (diff)
downloadapscheduler-26eefbbb5c40118887cd84ed4391356971e94135.tar.gz
Fixed compatibility with PyMongo 4
-rw-r--r--apscheduler/jobstores/mongodb.py4
-rw-r--r--docs/versionhistory.rst6
2 files changed, 8 insertions, 2 deletions
diff --git a/apscheduler/jobstores/mongodb.py b/apscheduler/jobstores/mongodb.py
index ea3097d..5a00f94 100644
--- a/apscheduler/jobstores/mongodb.py
+++ b/apscheduler/jobstores/mongodb.py
@@ -106,7 +106,7 @@ class MongoDBJobStore(BaseJobStore):
raise JobLookupError(job_id)
def remove_all_jobs(self):
- self.collection.remove()
+ self.collection.delete_many({})
def shutdown(self):
self.client.close()
@@ -133,7 +133,7 @@ class MongoDBJobStore(BaseJobStore):
# Remove all the jobs we failed to restore
if failed_job_ids:
- self.collection.remove({'_id': {'$in': failed_job_ids}})
+ self.collection.delete_many({'_id': {'$in': failed_job_ids}})
return jobs
diff --git a/docs/versionhistory.rst b/docs/versionhistory.rst
index 7c68381..24116e1 100644
--- a/docs/versionhistory.rst
+++ b/docs/versionhistory.rst
@@ -4,6 +4,12 @@ Version history
To find out how to migrate your application from a previous version of
APScheduler, see the :doc:`migration section <migration>`.
+UNRELEASED
+----------
+
+* Fixed compatibility with PyMongo 4
+
+
3.8.1
-----