summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/apscheduler/datastores/mongodb.py8
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: