# HG changeset patch # User drewp@bigasterisk.com # Date 1681717285 25200 # Node ID 1b388ee5dd09b7644f60fd35596f050d0ae55919 # Parent 071943adf0006c70a287f9c316b0e11dee5134b3 reformat diff -r 071943adf000 -r 1b388ee5dd09 src/ingest/IngestDrop.ts --- a/src/ingest/IngestDrop.ts Sun Apr 16 03:19:33 2023 -0700 +++ b/src/ingest/IngestDrop.ts Mon Apr 17 00:41:25 2023 -0700 @@ -17,6 +17,7 @@ } `, ]; + render() { return html`
Drop video url here
`; } diff -r 071943adf000 -r 1b388ee5dd09 video.py --- 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 diff -r 071943adf000 -r 1b388ee5dd09 vite.config.ts --- a/vite.config.ts Sun Apr 16 03:19:33 2023 -0700 +++ b/vite.config.ts Mon Apr 17 00:41:25 2023 -0700 @@ -18,7 +18,6 @@ formats: ["es"], }, }, - define: { global: {}, },