summaryrefslogtreecommitdiff
path: root/examples/web/asgi_starlette.py
diff options
context:
space:
mode:
authorAlex Grönholm <alex.gronholm@nextday.fi>2022-09-07 17:19:09 +0300
committerAlex Grönholm <alex.gronholm@nextday.fi>2022-09-07 17:20:19 +0300
commit4fff22e17cb915f637e96a51ddd8f7fd569eed07 (patch)
tree32242e27b777cd97968bac58263906f1f7f20e06 /examples/web/asgi_starlette.py
parent89bef78188912149248433210ccbcd6554291d24 (diff)
downloadapscheduler-4fff22e17cb915f637e96a51ddd8f7fd569eed07.tar.gz
Fixed examples not using shared data stores/event brokers
Diffstat (limited to 'examples/web/asgi_starlette.py')
-rw-r--r--examples/web/asgi_starlette.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/web/asgi_starlette.py b/examples/web/asgi_starlette.py
index 4288bfb..aaac3ac 100644
--- a/examples/web/asgi_starlette.py
+++ b/examples/web/asgi_starlette.py
@@ -59,7 +59,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)
routes = [Route("/", root)]
middleware = [Middleware(SchedulerMiddleware, scheduler=scheduler)]
app = Starlette(routes=routes, middleware=middleware)