diff options
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: |