diff options
author | Alex Grönholm <alex.gronholm@nextday.fi> | 2021-08-29 15:58:06 +0300 |
---|---|---|
committer | Alex Grönholm <alex.gronholm@nextday.fi> | 2021-08-29 16:08:49 +0300 |
commit | a0b7da22086b1704f52a3a34a3edb25f2bcd5d7e (patch) | |
tree | d7b25e7b1f29f968dd0968d2cb0ff511b3c8b56f /tests/conftest.py | |
parent | c0d757cb8357c71a1187078bb18b246195cb8911 (diff) | |
download | apscheduler-a0b7da22086b1704f52a3a34a3edb25f2bcd5d7e.tar.gz |
Switched to the src/ layout
Diffstat (limited to 'tests/conftest.py')
-rw-r--r-- | tests/conftest.py | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/tests/conftest.py b/tests/conftest.py index 1de47ed..62af791 100644 --- a/tests/conftest.py +++ b/tests/conftest.py @@ -3,6 +3,7 @@ from contextlib import asynccontextmanager, contextmanager from typing import AsyncContextManager, AsyncGenerator, ContextManager, Generator, Optional import pytest + from apscheduler.abc import AsyncDataStore, DataStore, Serializer from apscheduler.adapters import AsyncDataStoreAdapter from apscheduler.datastores.sync.memory import MemoryDataStore @@ -43,18 +44,20 @@ def setup_memory_store() -> Generator[DataStore, None, None]: @contextmanager def setup_mongodb_store() -> Generator[DataStore, None, None]: - from apscheduler.datastores.sync.mongodb import MongoDBDataStore from pymongo import MongoClient + from apscheduler.datastores.sync.mongodb import MongoDBDataStore + with MongoClient(tz_aware=True, serverSelectionTimeoutMS=1000) as client: yield MongoDBDataStore(client, start_from_scratch=True) @contextmanager def setup_sqlalchemy_store() -> Generator[DataStore, None, None]: - from apscheduler.datastores.sync.sqlalchemy import SQLAlchemyDataStore from sqlalchemy.future import create_engine + from apscheduler.datastores.sync.sqlalchemy import SQLAlchemyDataStore + engine = create_engine('postgresql+psycopg2://postgres:secret@localhost/testdb') try: yield SQLAlchemyDataStore(engine, start_from_scratch=True) @@ -64,9 +67,10 @@ def setup_sqlalchemy_store() -> Generator[DataStore, None, None]: @asynccontextmanager async def setup_async_sqlalchemy_store() -> AsyncGenerator[AsyncDataStore, None]: - from apscheduler.datastores.async_.sqlalchemy import SQLAlchemyDataStore from sqlalchemy.ext.asyncio import create_async_engine + from apscheduler.datastores.async_.sqlalchemy import SQLAlchemyDataStore + engine = create_async_engine('postgresql+asyncpg://postgres:secret@localhost/testdb', future=True) try: |