summaryrefslogtreecommitdiff
path: root/src/apscheduler/workers/sync.py
diff options
context:
space:
mode:
authorAlex Grönholm <alex.gronholm@nextday.fi>2022-01-01 23:34:37 +0200
committerAlex Grönholm <alex.gronholm@nextday.fi>2022-01-02 00:40:13 +0200
commit46076956fed73635ee05db51f9116096039e9cde (patch)
tree6dfea242ef0ff1f5fc807cb864275c1b381425ba /src/apscheduler/workers/sync.py
parenta9b8d6caa1db4afd29b769e52da7ddd937726c84 (diff)
downloadapscheduler-46076956fed73635ee05db51f9116096039e9cde.tar.gz
Upgraded attrs and its imports
We now import "attrs" instead of "attr".
Diffstat (limited to 'src/apscheduler/workers/sync.py')
-rw-r--r--src/apscheduler/workers/sync.py26
1 files changed, 13 insertions, 13 deletions
diff --git a/src/apscheduler/workers/sync.py b/src/apscheduler/workers/sync.py
index 6bac3ca..69718b5 100644
--- a/src/apscheduler/workers/sync.py
+++ b/src/apscheduler/workers/sync.py
@@ -11,7 +11,7 @@ from logging import Logger, getLogger
from typing import Callable, Optional
from uuid import UUID
-import attr
+import attrs
from ..abc import DataStore, EventSource
from ..context import current_worker, job_info
@@ -22,21 +22,21 @@ from ..structures import Job, JobInfo, JobResult
from ..validators import positive_integer
-@attr.define(eq=False)
+@attrs.define(eq=False)
class Worker:
"""Runs jobs locally in a thread pool."""
data_store: DataStore
- max_concurrent_jobs: int = attr.field(kw_only=True, validator=positive_integer, default=20)
- identity: str = attr.field(kw_only=True, default=None)
- logger: Optional[Logger] = attr.field(kw_only=True, default=getLogger(__name__))
-
- _state: RunState = attr.field(init=False, default=RunState.stopped)
- _wakeup_event: threading.Event = attr.field(init=False)
- _acquired_jobs: set[Job] = attr.field(init=False, factory=set)
- _events: LocalEventBroker = attr.field(init=False, factory=LocalEventBroker)
- _running_jobs: set[UUID] = attr.field(init=False, factory=set)
- _exit_stack: ExitStack = attr.field(init=False)
- _executor: ThreadPoolExecutor = attr.field(init=False)
+ max_concurrent_jobs: int = attrs.field(kw_only=True, validator=positive_integer, default=20)
+ identity: str = attrs.field(kw_only=True, default=None)
+ logger: Optional[Logger] = attrs.field(kw_only=True, default=getLogger(__name__))
+
+ _state: RunState = attrs.field(init=False, default=RunState.stopped)
+ _wakeup_event: threading.Event = attrs.field(init=False)
+ _acquired_jobs: set[Job] = attrs.field(init=False, factory=set)
+ _events: LocalEventBroker = attrs.field(init=False, factory=LocalEventBroker)
+ _running_jobs: set[UUID] = attrs.field(init=False, factory=set)
+ _exit_stack: ExitStack = attrs.field(init=False)
+ _executor: ThreadPoolExecutor = attrs.field(init=False)
def __attrs_post_init__(self) -> None:
if not self.identity: