revert control loop and move pipeline = None

Author: eliteprox

runner/app/live/streamer/process.py

@@ -109,7 +109,6 @@ def get_recent_logs(self, n=None) -> list[str]:
 
     def process_loop(self):
         self._setup_logging()
-#        pipeline = None
 
         # Ensure CUDA environment is available inside the subprocess.
         # Multiprocessing (spawn mode) does not inherit environment variables by default,
@@ -142,6 +141,7 @@ def _handle_logging_params(self, params: dict) -> dict:
 
     async def _initialize_pipeline(self):
         try:
+            pipeline = None
             stream_id = ""
             params = {}
             try:
@@ -173,6 +173,7 @@ async def _run_pipeline_loops(self):
         output_task = asyncio.create_task(self._output_loop(pipeline))
         param_task = asyncio.create_task(self._param_update_loop(pipeline))
 
+
         async def wait_for_stop():
             while not self.is_done():
                 await asyncio.sleep(0.1)

runner/app/live/streamer/streamer.py

@@ -54,11 +54,12 @@ async def start(self, params: dict):
         self.main_tasks = [
             run_in_background("ingress_loop", self.run_ingress_loop()),
             run_in_background("egress_loop", self.run_egress_loop()),
-            run_in_background("report_status_loop", self.report_status_loop())
+            run_in_background("report_status_loop", self.report_status_loop()),
+            run_in_background("control_loop", self.run_control_loop())
         ]
         # auxiliary tasks that are not critical to the supervisor, but which we want to run
         self.auxiliary_tasks = [
-            run_in_background("control_loop", self.run_control_loop())
+            
         ]
         self.tasks_supervisor_task = run_in_background(
             "tasks_supervisor", self.tasks_supervisor()