From e0cb052d11b93c3bc4ea7fcffdf90330362850fd Mon Sep 17 00:00:00 2001 From: Brad P Date: Tue, 22 Jul 2025 11:19:39 -0500 Subject: [PATCH 1/3] add data_url to routes and openapi gen --- runner/app/pipelines/live_video_to_video.py | 3 ++- runner/app/routes/live_video_to_video.py | 7 +++++++ 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/runner/app/pipelines/live_video_to_video.py b/runner/app/pipelines/live_video_to_video.py index 3b29a96dc..bc8772f30 100644 --- a/runner/app/pipelines/live_video_to_video.py +++ b/runner/app/pipelines/live_video_to_video.py @@ -30,7 +30,7 @@ def __init__(self, model_id: str): self.start_process() def __call__( # type: ignore - self, *, subscribe_url: str, publish_url: str, control_url: str, events_url: str, params: dict, request_id: str, manifest_id: str, stream_id: str, **kwargs + self, *, subscribe_url: str, publish_url: str, control_url: str, events_url: str, data_url: str, params: dict, request_id: str, manifest_id: str, stream_id: str, **kwargs ): if not self.process: raise RuntimeError("Pipeline process not running") @@ -51,6 +51,7 @@ def __call__( # type: ignore "publish_url": publish_url, "control_url": control_url, "events_url": events_url, + "data_url": data_url, "params": params, "request_id": request_id or "", "manifest_id": manifest_id or "", diff --git a/runner/app/routes/live_video_to_video.py b/runner/app/routes/live_video_to_video.py index 5614ba898..2967c3f17 100644 --- a/runner/app/routes/live_video_to_video.py +++ b/runner/app/routes/live_video_to_video.py @@ -58,6 +58,13 @@ class LiveVideoToVideoParams(BaseModel): description="URL for publishing events via Trickle protocol for pipeline status and logs.", ), ] + data_url: Annotated[ + str, + Field( + default="", + description="URL for publishing data via Trickle protocol for pipeline status and logs.", + ), + ] model_id: Annotated[ str, Field( From 33de59fc45f4a0080af0d4918f4821dfad033c65 Mon Sep 17 00:00:00 2001 From: Brad P Date: Tue, 22 Jul 2025 11:22:54 -0500 Subject: [PATCH 2/3] update openapi for live-video-to-video data_url --- runner/gateway.openapi.yaml | 6 ++++++ runner/openapi.yaml | 6 ++++++ 2 files changed, 12 insertions(+) diff --git a/runner/gateway.openapi.yaml b/runner/gateway.openapi.yaml index 177813ef3..e5039f3ae 100644 --- a/runner/gateway.openapi.yaml +++ b/runner/gateway.openapi.yaml @@ -1000,6 +1000,12 @@ components: description: URL for publishing events via Trickle protocol for pipeline status and logs. default: '' + data_url: + type: string + title: Data Url + description: URL for publishing data via Trickle protocol for pipeline status + and logs. + default: '' model_id: type: string title: Model Id diff --git a/runner/openapi.yaml b/runner/openapi.yaml index 28756adf8..8471c98d1 100644 --- a/runner/openapi.yaml +++ b/runner/openapi.yaml @@ -1158,6 +1158,12 @@ components: description: URL for publishing events via Trickle protocol for pipeline status and logs. default: '' + data_url: + type: string + title: Data Url + description: URL for publishing data via Trickle protocol for pipeline status + and logs. + default: '' model_id: type: string title: Model Id From c37be6956bd07eddb1a8e5b806bb1a9d3e0b21a8 Mon Sep 17 00:00:00 2001 From: Brad P Date: Wed, 20 Aug 2025 11:08:20 -0500 Subject: [PATCH 3/3] add data_url field to LiveVideoToVideoResponse --- runner/app/routes/utils.py | 4 ++++ runner/gateway.openapi.yaml | 5 +++++ runner/openapi.yaml | 5 +++++ 3 files changed, 14 insertions(+) diff --git a/runner/app/routes/utils.py b/runner/app/routes/utils.py index 5ed185f8b..b9f9cdacb 100644 --- a/runner/app/routes/utils.py +++ b/runner/app/routes/utils.py @@ -131,6 +131,10 @@ class LiveVideoToVideoResponse(BaseModel): default='', description="URL for subscribing to events for pipeline status and logs", ) + data_url: str = Field( + default='', + description="URL for publishing data for pipeline", + ) request_id: str = Field( default='', description="The ID generated for this request", diff --git a/runner/gateway.openapi.yaml b/runner/gateway.openapi.yaml index e5039f3ae..573ad163c 100644 --- a/runner/gateway.openapi.yaml +++ b/runner/gateway.openapi.yaml @@ -1061,6 +1061,11 @@ components: title: Events Url description: URL for subscribing to events for pipeline status and logs default: '' + data_url: + type: string + title: Data Url + description: URL for publishing data for pipeline + default: '' request_id: type: string title: Request Id diff --git a/runner/openapi.yaml b/runner/openapi.yaml index 8471c98d1..45297e527 100644 --- a/runner/openapi.yaml +++ b/runner/openapi.yaml @@ -1218,6 +1218,11 @@ components: title: Events Url description: URL for subscribing to events for pipeline status and logs default: '' + data_url: + type: string + title: Data Url + description: URL for publishing data for pipeline + default: '' request_id: type: string title: Request Id