Tested SQLAlchemy data store against MySQL, and fixed missing "await"

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(