Fixed examples not using shared data stores/event brokers

4 files changed, 7 insertions, 5 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)
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)
diff --git a/examples/web/wsgi_flask.py b/examples/web/wsgi_flask.py
index cc74c7b..0574d25 100644
--- a/examples/web/wsgi_flask.py
+++ b/examples/web/wsgi_flask.py
@@ -1,7 +1,7 @@
 """
 Example demonstrating use with WSGI (raw WSGI application, no framework).
 
-Requires the "postgresql" service to be running.
+Requires the "postgresql" and "redis" services to be running.
 To install prerequisites: pip install sqlalchemy psycopg2 flask uwsgi
 To run: uwsgi -T --http :8000 --wsgi-file wsgi_flask.py
 
diff --git a/examples/web/wsgi_noframework.py b/examples/web/wsgi_noframework.py
index c143f3f..22ebb21 100644
--- a/examples/web/wsgi_noframework.py
+++ b/examples/web/wsgi_noframework.py
@@ -1,7 +1,7 @@
 """
 Example demonstrating use with WSGI (raw WSGI application, no framework).
 
-Requires the "postgresql" service to be running.
+Requires the "postgresql" and "redis" services to be running.
 To install prerequisites: pip install sqlalchemy psycopg2 uwsgi
 To run: uwsgi -T --http :8000 --wsgi-file wsgi_noframework.py
 
@@ -16,6 +16,7 @@ from datetime import datetime
 from sqlalchemy.future import create_engine
 
 from apscheduler.datastores.sqlalchemy import SQLAlchemyDataStore
+from apscheduler.eventbrokers.redis import RedisEventBroker
 from apscheduler.schedulers.sync import Scheduler
 from apscheduler.triggers.interval import IntervalTrigger
 
@@ -36,6 +37,7 @@ def application(environ, start_response):
 
 engine = create_engine("postgresql+psycopg2://postgres:secret@localhost/testdb")
 data_store = SQLAlchemyDataStore(engine)
-scheduler = Scheduler(data_store)
+event_broker = RedisEventBroker.from_url("redis://localhost")
+scheduler = Scheduler(data_store, event_broker)
 scheduler.add_schedule(tick, IntervalTrigger(seconds=1), id="tick")
 scheduler.start_in_background()