diff options
author | Alex Grönholm <alex.gronholm@nextday.fi> | 2021-09-02 20:08:00 +0300 |
---|---|---|
committer | Alex Grönholm <alex.gronholm@nextday.fi> | 2021-09-06 01:39:07 +0300 |
commit | fa522949af87c2615592b0342b00c0ee6af1bdde (patch) | |
tree | b0a56b592afc0288220473b1f7394019c960d579 | |
parent | 31a95f813ea5cd891204452bfc87cd046eec4bca (diff) | |
download | apscheduler-fa522949af87c2615592b0342b00c0ee6af1bdde.tar.gz |
Moved the sync data store adapter to datastores/async_/
-rw-r--r-- | src/apscheduler/datastores/async_/sync_adapter.py (renamed from src/apscheduler/adapters.py) | 12 | ||||
-rw-r--r-- | src/apscheduler/schedulers/async_.py | 2 | ||||
-rw-r--r-- | src/apscheduler/workers/async_.py | 2 | ||||
-rw-r--r-- | tests/conftest.py | 2 |
4 files changed, 9 insertions, 9 deletions
diff --git a/src/apscheduler/adapters.py b/src/apscheduler/datastores/async_/sync_adapter.py index d9fbb10..2bb691e 100644 --- a/src/apscheduler/adapters.py +++ b/src/apscheduler/datastores/async_/sync_adapter.py @@ -9,12 +9,12 @@ import attr from anyio import to_thread from anyio.from_thread import BlockingPortal -from . import events -from .abc import AsyncDataStore, DataStore -from .events import Event, SubscriptionToken -from .policies import ConflictPolicy -from .structures import Job, JobResult, Schedule -from .util import reentrant +from ... import events +from ...abc import AsyncDataStore, DataStore +from ...events import Event, SubscriptionToken +from ...policies import ConflictPolicy +from ...structures import Job, JobResult, Schedule +from ...util import reentrant @reentrant diff --git a/src/apscheduler/schedulers/async_.py b/src/apscheduler/schedulers/async_.py index 3f33921..9b69514 100644 --- a/src/apscheduler/schedulers/async_.py +++ b/src/apscheduler/schedulers/async_.py @@ -14,7 +14,7 @@ from anyio import ( from anyio.abc import TaskGroup from ..abc import AsyncDataStore, DataStore, EventSource, Job, Schedule, Trigger -from ..adapters import AsyncDataStoreAdapter +from ..datastores.async_.sync_adapter import AsyncDataStoreAdapter from ..datastores.sync.memory import MemoryDataStore from ..enums import RunState from ..events import ( diff --git a/src/apscheduler/workers/async_.py b/src/apscheduler/workers/async_.py index 594e5c6..79b0143 100644 --- a/src/apscheduler/workers/async_.py +++ b/src/apscheduler/workers/async_.py @@ -14,7 +14,7 @@ from anyio import TASK_STATUS_IGNORED, create_task_group, get_cancelled_exc_clas from anyio.abc import CancelScope, TaskGroup from ..abc import AsyncDataStore, DataStore, EventSource, Job -from ..adapters import AsyncDataStoreAdapter +from ..datastores.async_.sync_adapter import AsyncDataStoreAdapter from ..enums import JobOutcome, RunState from ..events import ( AsyncEventHub, Event, JobAdded, JobCancelled, JobCompleted, JobDeadlineMissed, JobFailed, diff --git a/tests/conftest.py b/tests/conftest.py index f88fad6..13d3dea 100644 --- a/tests/conftest.py +++ b/tests/conftest.py @@ -6,7 +6,7 @@ from typing import AsyncContextManager, AsyncGenerator, ContextManager, Generato import pytest from apscheduler.abc import AsyncDataStore, DataStore, Serializer -from apscheduler.adapters import AsyncDataStoreAdapter +from apscheduler.datastores.async_.sync_adapter import AsyncDataStoreAdapter from apscheduler.datastores.sync.memory import MemoryDataStore from apscheduler.serializers.cbor import CBORSerializer from apscheduler.serializers.json import JSONSerializer |