live/streamer: Give grace period on params update as well

livepeer · Dec 13, 2024 · 1caba03 · 1caba03
1 parent 0141b9d
commit 1caba03
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/runner/app/live/streamer/streamer.py b/runner/app/live/streamer/streamer.py
@@ -231,7 +231,8 @@ def _current_state(self) -> PipelineState:
             return PipelineState.DEGRADED_INPUT
 
         inference = self.status.inference_status
-        if not inference.last_output_time and current_time - self.status.start_time < 30:
+        pipeline_load_time = max(self.status.start_time, inference.last_params_update_time or 0)
+        if not inference.last_output_time and current_time - pipeline_load_time < 30:
             # 30s grace period for the pipeline to start
             return PipelineState.ONLINE