diff --git a/schedule/src/schedule/application/__init__.py b/schedule/src/schedule/application/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/schedule/src/schedule/service.py b/schedule/src/schedule/application/service.py similarity index 100% rename from schedule/src/schedule/service.py rename to schedule/src/schedule/application/service.py diff --git a/schedule/src/schedule/execution/worker.py b/schedule/src/schedule/execution/worker.py index e163758..7743618 100644 --- a/schedule/src/schedule/execution/worker.py +++ b/schedule/src/schedule/execution/worker.py @@ -87,7 +87,7 @@ class NodeExecutor: store = self._bucket_stores.get(bucket_name) if store is not None: return store - from schedule.service import build_object_store + from schedule.application.service import build_object_store store = build_object_store(bucket_name=bucket_name) self._bucket_stores[bucket_name] = store diff --git a/schedule/src/schedule/main.py b/schedule/src/schedule/main.py index 3c978f3..b517314 100644 --- a/schedule/src/schedule/main.py +++ b/schedule/src/schedule/main.py @@ -9,7 +9,7 @@ from common.db import create_database_engine, create_session_factory from common.service_app import create_service_app from loguru import logger -from schedule.service import ( +from schedule.application.service import ( SchedulerService, build_object_store, build_storage_http_client, diff --git a/schedule/src/schedule/worker.py b/schedule/src/schedule/worker.py index e163758..7743618 100644 --- a/schedule/src/schedule/worker.py +++ b/schedule/src/schedule/worker.py @@ -87,7 +87,7 @@ class NodeExecutor: store = self._bucket_stores.get(bucket_name) if store is not None: return store - from schedule.service import build_object_store + from schedule.application.service import build_object_store store = build_object_store(bucket_name=bucket_name) self._bucket_stores[bucket_name] = store diff --git a/schedule/tests/test_worker.py b/schedule/tests/test_worker.py index 7f9e89c..57dd630 100644 --- a/schedule/tests/test_worker.py +++ b/schedule/tests/test_worker.py @@ -61,7 +61,7 @@ def test_store_for_custom_bucket_uses_build_factory(monkeypatch: pytest.MonkeyPa """A custom bucket_name must produce a store via ``build_object_store``.""" custom_store = MagicMock(name="custom_store") with patch( - "schedule.service.build_object_store", + "schedule.application.service.build_object_store", return_value=custom_store, ) as mock_build: executor, _, _ = _make_executor() @@ -75,7 +75,7 @@ def test_store_for_custom_bucket_is_cached(monkeypatch: pytest.MonkeyPatch) -> N """Repeated lookups for the same custom bucket must hit the cache.""" custom_store = MagicMock(name="custom_store") with patch( - "schedule.service.build_object_store", + "schedule.application.service.build_object_store", return_value=custom_store, ) as mock_build: executor, _, _ = _make_executor()