summaryrefslogtreecommitdiff
path: root/src/apscheduler/workers
diff options
context:
space:
mode:
Diffstat (limited to 'src/apscheduler/workers')
-rw-r--r--src/apscheduler/workers/async_.py2
-rw-r--r--src/apscheduler/workers/sync.py2
2 files changed, 2 insertions, 2 deletions
diff --git a/src/apscheduler/workers/async_.py b/src/apscheduler/workers/async_.py
index ffd6e4d..f15465f 100644
--- a/src/apscheduler/workers/async_.py
+++ b/src/apscheduler/workers/async_.py
@@ -20,12 +20,12 @@ from anyio import (
)
from anyio.abc import CancelScope, TaskGroup
+from .._context import current_worker, job_info
from .._converters import as_async_datastore, as_async_eventbroker
from .._enums import JobOutcome, RunState
from .._structures import Job, JobInfo, JobResult
from .._validators import positive_integer
from ..abc import AsyncDataStore, AsyncEventBroker
-from ..context import current_worker, job_info
from ..eventbrokers.async_local import LocalAsyncEventBroker
from ..events import JobAdded, WorkerStarted, WorkerStopped
diff --git a/src/apscheduler/workers/sync.py b/src/apscheduler/workers/sync.py
index 61f23ad..2dbeaf9 100644
--- a/src/apscheduler/workers/sync.py
+++ b/src/apscheduler/workers/sync.py
@@ -15,11 +15,11 @@ from uuid import UUID
import attrs
+from .._context import current_worker, job_info
from .._enums import JobOutcome, RunState
from .._structures import Job, JobInfo, JobResult
from .._validators import positive_integer
from ..abc import DataStore, EventBroker
-from ..context import current_worker, job_info
from ..eventbrokers.local import LocalEventBroker
from ..events import JobAdded, WorkerStarted, WorkerStopped