Revert "fix: process stderr (#450)" (#453)

This reverts commit c7520cb.

Author: victorges

runner/app/live/streamer/process_guardian.py

@@ -251,15 +251,8 @@ async def _monitor_loop(self):
                     and time_since_last_output < 60
                 )
                 if stopped_recently or gone_stale:
-                    logging.error(
-                        f"No output received while inputs are being sent. Restarting process. \
-                        stopped_recently={stopped_recently} \
-                        gone_stale={gone_stale} \
-                        time_since_last_input={time_since_last_input} \
-                        time_since_last_output={time_since_last_output} \
-                        time_since_start={time_since_start} \
-                        time_since_last_params={time_since_last_params} \
-                        time_since_reload={time_since_reload}"
+                    logging.warning(
+                        "No output received while inputs are being sent. Restarting process."
                     )
                     await self._restart_process()
         except asyncio.CancelledError:

runner/app/pipelines/live_video_to_video.py

@@ -122,10 +122,8 @@ def start_process(self, **kwargs):
 
             self.monitor_thread = threading.Thread(target=self.monitor_process)
             self.monitor_thread.start()
-            self.stdout_thread = threading.Thread(target=log_output, args=(self.process.stdout,))
-            self.stdout_thread.start()
-            self.stderr_thread = threading.Thread(target=log_output, args=(self.process.stderr,))
-            self.stderr_thread.start()
+            self.log_thread = threading.Thread(target=log_output, args=(self.process.stdout,))
+            self.log_thread.start()
 
         except subprocess.CalledProcessError as e:
             raise InferenceError(f"Error starting infer.py: {e}")
@@ -174,12 +172,9 @@ def stop_process(self, is_monitor_thread: bool = False):
         if self.monitor_thread and not is_monitor_thread:
             self.monitor_thread.join()
             self.monitor_thread = None
-        if self.stdout_thread:
-            self.stdout_thread.join()
-            self.stdout_thread = None
-        if self.stderr_thread:
-            self.stderr_thread.join()
-            self.stderr_thread = None
+        if self.log_thread:
+            self.log_thread.join()
+            self.log_thread = None
         logging.info("Infer process stopped successfully")
 
     def __str__(self) -> str: