summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlex Grönholm <alex.gronholm@nextday.fi>2021-09-02 20:08:00 +0300
committerAlex Grönholm <alex.gronholm@nextday.fi>2021-09-06 01:39:07 +0300
commitfa522949af87c2615592b0342b00c0ee6af1bdde (patch)
treeb0a56b592afc0288220473b1f7394019c960d579
parent31a95f813ea5cd891204452bfc87cd046eec4bca (diff)
downloadapscheduler-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_.py2
-rw-r--r--src/apscheduler/workers/async_.py2
-rw-r--r--tests/conftest.py2
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