Get requestID and streamID from request body

Author: mjh1

runner/app/live/log.py

@@ -30,7 +30,7 @@ def config_logging(*, log_level: int = 0, request_id: str = "", stream_id: str =
 
 def config_logging_fields(handler: logging.Handler, request_id: str, stream_id: str):
     formatter = logging.Formatter(
-        "timestamp=%(asctime)s level=%(levelname)s location=%(filename)s:%(lineno)d:%(funcName)s request_id=%(request_id)s stream_id=%(stream_id)s message=%(message)s",
+        "timestamp=%(asctime)s level=%(levelname)s location=%(filename)s:%(lineno)d:%(funcName)s gateway_request_id=%(request_id)s stream_id=%(stream_id)s message=%(message)s",
         defaults={"request_id": request_id, "stream_id": stream_id},
         datefmt="%Y-%m-%d %H:%M:%S",
     )

runner/app/routes/live_video_to_video.py

@@ -144,6 +144,11 @@ async def live_video_to_video(
         )
 
     try:
+        if requestID is None:
+            requestID = params.gateway_request_id
+        if streamID is None:
+            streamID = params.stream_id
+        logger.error(f"AAA live_video_to_video: {requestID} {streamID}")
         pipeline(**params.model_dump(), request_id=requestID, stream_id=streamID)
     except Exception as e:
         if isinstance(e, torch.cuda.OutOfMemoryError):