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