Mercurial > code > home > repos > video
diff video.py @ 18:1b388ee5dd09
reformat
author | drewp@bigasterisk.com |
---|---|
date | Mon, 17 Apr 2023 00:41:25 -0700 |
parents | 071943adf000 |
children | cf6842952e13 |
line wrap: on
line diff
--- a/video.py Sun Apr 16 03:19:33 2023 -0700 +++ b/video.py Mon Apr 17 00:41:25 2023 -0700 @@ -14,6 +14,7 @@ from video_file_store import VideoFileStore from video_ingest import VideoIngest import dl_queue + logging.basicConfig(level=logging.DEBUG) log = logging.getLogger() logging.getLogger('sse_starlette').setLevel(logging.WARNING) @@ -50,15 +51,18 @@ async def ingestQueue(req: Request) -> EventSourceResponse: + async def g(): async for ev in svc.events(): yield json.dumps(ev) + return EventSourceResponse(g()) store = VideoFileStore(top=Path('/data')) svc = VideoIngest(store) + def main(): app = Starlette( @@ -78,7 +82,7 @@ app.add_middleware(PrometheusMiddleware, app_name='video_api') app.add_route("/metrics", handle_metrics) - + app.state.processTask = asyncio.create_task(dl_queue.process()) return app