summaryrefslogtreecommitdiff
path: root/src/apscheduler/_events.py
diff options
context:
space:
mode:
Diffstat (limited to 'src/apscheduler/_events.py')
-rw-r--r--src/apscheduler/_events.py30
1 files changed, 2 insertions, 28 deletions
diff --git a/src/apscheduler/_events.py b/src/apscheduler/_events.py
index a3bd297..9d0278d 100644
--- a/src/apscheduler/_events.py
+++ b/src/apscheduler/_events.py
@@ -206,34 +206,8 @@ class SchedulerStopped(SchedulerEvent):
exception: BaseException | None = None
-#
-# Worker events
-#
-
-
-@attrs.define(kw_only=True, frozen=True)
-class WorkerEvent(Event):
- """Base class for events originating from a worker."""
-
-
-@attrs.define(kw_only=True, frozen=True)
-class WorkerStarted(WorkerEvent):
- """Signals that a worker has started."""
-
-
-@attrs.define(kw_only=True, frozen=True)
-class WorkerStopped(WorkerEvent):
- """
- Signals that a worker has stopped.
-
- :ivar exception: the exception that caused the worker to stop, if any
- """
-
- exception: BaseException | None = None
-
-
@attrs.define(kw_only=True, frozen=True)
-class JobAcquired(WorkerEvent):
+class JobAcquired(SchedulerEvent):
"""
Signals that a worker has acquired a job for processing.
@@ -246,7 +220,7 @@ class JobAcquired(WorkerEvent):
@attrs.define(kw_only=True, frozen=True)
-class JobReleased(WorkerEvent):
+class JobReleased(SchedulerEvent):
"""
Signals that a worker has finished processing of a job.