diff options
Diffstat (limited to 'src/apscheduler/_events.py')
-rw-r--r-- | src/apscheduler/_events.py | 30 |
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. |