diff options
| author | Alex Grönholm <alex.gronholm@nextday.fi> | 2022-08-14 01:14:52 +0300 |
|---|---|---|
| committer | Alex Grönholm <alex.gronholm@nextday.fi> | 2022-08-14 01:14:52 +0300 |
| commit | 03a429a7e52cdcb71922aa27b89ec08337f3f4cf (patch) | |
| tree | de8ca90773aa2531bf73a1d8c5b1d0ed65aecac4 /src | |
| parent | a9141bb5663e0a22cc7c4da7d34834c925dbadea (diff) | |
| download | apscheduler-03a429a7e52cdcb71922aa27b89ec08337f3f4cf.tar.gz | |
Don't emit JobReleased events from the MongoDB store
Diffstat (limited to 'src')
| -rw-r--r-- | src/apscheduler/datastores/mongodb.py | 8 |
1 files changed, 0 insertions, 8 deletions
diff --git a/src/apscheduler/datastores/mongodb.py b/src/apscheduler/datastores/mongodb.py index de209ba..13299bb 100644 --- a/src/apscheduler/datastores/mongodb.py +++ b/src/apscheduler/datastores/mongodb.py @@ -22,7 +22,6 @@ from .._events import ( DataStoreEvent, JobAcquired, JobAdded, - JobReleased, ScheduleAdded, ScheduleRemoved, ScheduleUpdated, @@ -510,13 +509,6 @@ class MongoDBDataStore(BaseDataStore): # Delete the job self._jobs.delete_one({"_id": result.job_id}, session=session) - # Publish the event - self._events.publish( - JobReleased( - job_id=result.job_id, worker_id=worker_id, outcome=result.outcome - ) - ) - def get_job_result(self, job_id: UUID) -> JobResult | None: for attempt in self._retry(): with attempt: |