diff options
Diffstat (limited to 'examples/web/asgi_fastapi.py')
| -rw-r--r-- | examples/web/asgi_fastapi.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/examples/web/asgi_fastapi.py b/examples/web/asgi_fastapi.py index 4a3872d..904ee19 100644 --- a/examples/web/asgi_fastapi.py +++ b/examples/web/asgi_fastapi.py @@ -20,7 +20,7 @@ from fastapi.responses import PlainTextResponse, Response from sqlalchemy.ext.asyncio import create_async_engine from starlette.types import ASGIApp, Receive, Scope, Send -from apscheduler.datastores.async_sqlalchemy import AsyncSQLAlchemyDataStore +from apscheduler.datastores.sqlalchemy import SQLAlchemyDataStore from apscheduler.eventbrokers.asyncpg import AsyncpgEventBroker from apscheduler.schedulers.async_ import AsyncScheduler from apscheduler.triggers.interval import IntervalTrigger @@ -56,7 +56,7 @@ async def root(request: Request) -> Response: engine = create_async_engine("postgresql+asyncpg://postgres:secret@localhost/testdb") -data_store = AsyncSQLAlchemyDataStore(engine) +data_store = SQLAlchemyDataStore(engine) event_broker = AsyncpgEventBroker.from_async_sqla_engine(engine) scheduler = AsyncScheduler(data_store, event_broker) middleware = [Middleware(SchedulerMiddleware, scheduler=scheduler)] |