summaryrefslogtreecommitdiff
path: root/examples/web/asgi_fastapi.py
diff options
context:
space:
mode:
Diffstat (limited to 'examples/web/asgi_fastapi.py')
-rw-r--r--examples/web/asgi_fastapi.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/web/asgi_fastapi.py b/examples/web/asgi_fastapi.py
index ffa79cb..4a3872d 100644
--- a/examples/web/asgi_fastapi.py
+++ b/examples/web/asgi_fastapi.py
@@ -58,7 +58,7 @@ async def root(request: Request) -> Response:
engine = create_async_engine("postgresql+asyncpg://postgres:secret@localhost/testdb")
data_store = AsyncSQLAlchemyDataStore(engine)
event_broker = AsyncpgEventBroker.from_async_sqla_engine(engine)
-scheduler = AsyncScheduler()
+scheduler = AsyncScheduler(data_store, event_broker)
middleware = [Middleware(SchedulerMiddleware, scheduler=scheduler)]
app = FastAPI(middleware=middleware)
app.add_api_route("/", root)