Mercurial > code > home > repos > video
changeset 18:1b388ee5dd09
reformat
author | drewp@bigasterisk.com |
---|---|
date | Mon, 17 Apr 2023 00:41:25 -0700 |
parents | 071943adf000 |
children | f0a773084a2e |
files | src/ingest/IngestDrop.ts video.py vite.config.ts |
diffstat | 3 files changed, 6 insertions(+), 2 deletions(-) [+] |
line wrap: on
line diff
--- 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` <div id="drop" @dragover=${this.dragover} @dragleave=${this.leave} @drop=${this.drop}>Drop video url here</div> `; }
--- 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