added is_preview flag on webrtc (#1942)

Author: rafel-roboflow

inference/core/interfaces/stream/inference_pipeline.py

@@ -488,6 +488,7 @@ def init_with_workflow(
         predictions_queue_size: int = PREDICTIONS_QUEUE_SIZE,
         decoding_buffer_size: int = DEFAULT_BUFFER_SIZE,
         model_manager: Optional[ModelManager] = None,
+        _is_preview: bool = False,
     ) -> "InferencePipeline":
         """
         This class creates the abstraction for making inferences from given workflow against video stream.
@@ -658,6 +659,7 @@ def init_with_workflow(
                 image_input_name=image_input_name,
                 video_metadata_input_name=video_metadata_input_name,
                 serialize_results=serialize_results,
+                _is_preview=_is_preview,
             )
         except ImportError as error:
             raise CannotInitialiseModelError(

inference/core/interfaces/stream/model_handlers/workflows.py

@@ -15,6 +15,7 @@ def run_workflow(
         image_input_name: str,
         video_metadata_input_name: str,
         serialize_results: bool = False,
+        _is_preview: bool = False,
     ) -> List[dict]:
         if workflows_parameters is None:
             workflows_parameters = {}
@@ -55,4 +56,5 @@ def run_workflow(
             runtime_parameters=workflows_parameters,
             fps=fps,
             serialize_results=serialize_results,
+            _is_preview=_is_preview,
         )

inference/core/interfaces/webrtc_worker/webrtc.py

@@ -302,6 +302,7 @@ def __init__(
         terminate_event: Optional[asyncio.Event] = None,
         heartbeat_callback: Optional[Callable[[], None]] = None,
         realtime_processing: bool = True,
+        is_preview: bool = False,
     ):
         self._loop = asyncio_loop
         self._termination_date = termination_date
@@ -361,6 +362,7 @@ def __init__(
             cancel_thread_pool_tasks_on_exit=workflow_configuration.cancel_thread_pool_tasks_on_exit,
             video_metadata_input_name=workflow_configuration.video_metadata_input_name,
             model_manager=model_manager,
+            _is_preview=is_preview,
         )
 
     def set_track(self, track: MediaStreamTrack, rotation_code: Optional[int] = None):
@@ -728,6 +730,7 @@ def __init__(
         terminate_event: Optional[asyncio.Event] = None,
         heartbeat_callback: Optional[Callable[[], None]] = None,
         realtime_processing: bool = True,
+        is_preview: bool = False,
         *args,
         **kwargs,
     ):
@@ -746,6 +749,7 @@ def __init__(
             model_manager=model_manager,
             heartbeat_callback=heartbeat_callback,
             realtime_processing=realtime_processing,
+            is_preview=is_preview,
         )
 
     async def _auto_detect_stream_output(
@@ -918,6 +922,7 @@ async def init_rtc_peer_connection_with_loop(
                 terminate_event=terminate_event,
                 heartbeat_callback=heartbeat_callback,
                 realtime_processing=webrtc_request.webrtc_realtime_processing,
+                is_preview=webrtc_request.is_preview,
             )
         else:
             # No video track - use base VideoFrameProcessor
@@ -934,6 +939,7 @@ async def init_rtc_peer_connection_with_loop(
                 terminate_event=terminate_event,
                 heartbeat_callback=heartbeat_callback,
                 realtime_processing=webrtc_request.webrtc_realtime_processing,
+                is_preview=webrtc_request.is_preview,
             )
     except (
         ValidationError,