diff options
author | Alex Grönholm <alex.gronholm@nextday.fi> | 2022-07-26 19:49:41 +0300 |
---|---|---|
committer | Alex Grönholm <alex.gronholm@nextday.fi> | 2022-07-27 13:02:08 +0300 |
commit | 032e5ef97fb252227717f21a7150cc73e19f41c3 (patch) | |
tree | 49360033338f1264d8c4f58e214535c8673458f9 /tests/test_datastores.py | |
parent | 14862581e46da0698d63e98558f9932e5fc0b7e1 (diff) | |
download | apscheduler-032e5ef97fb252227717f21a7150cc73e19f41c3.tar.gz |
Tested SQLAlchemy data store against MySQL, and fixed missing "await"
Diffstat (limited to 'tests/test_datastores.py')
-rw-r--r-- | tests/test_datastores.py | 20 |
1 files changed, 20 insertions, 0 deletions
diff --git a/tests/test_datastores.py b/tests/test_datastores.py index bac6113..e838d9c 100644 --- a/tests/test_datastores.py +++ b/tests/test_datastores.py @@ -117,6 +117,21 @@ async def asyncpg_store() -> AsyncDataStore: @pytest.fixture +async def asyncmy_store() -> AsyncDataStore: + from sqlalchemy.ext.asyncio import create_async_engine + + from apscheduler.datastores.async_sqlalchemy import AsyncSQLAlchemyDataStore + + engine = create_async_engine( + "mysql+asyncmy://root:secret@localhost/testdb?charset=utf8mb4", future=True + ) + try: + yield AsyncSQLAlchemyDataStore(engine, start_from_scratch=True) + finally: + await engine.dispose() + + +@pytest.fixture def schedules() -> list[Schedule]: trigger = DateTrigger(datetime(2020, 9, 13, tzinfo=timezone.utc)) schedule1 = Schedule(id="s1", task_id="task1", trigger=trigger) @@ -623,6 +638,11 @@ class TestAsyncDataStores: id="asyncpg", marks=[pytest.mark.external_service], ), + pytest.param( + lazy_fixture("asyncmy_store"), + id="asyncmy", + marks=[pytest.mark.external_service], + ), ] ) async def raw_datastore( |