Update rvc_service.py

rvc_service.py

@@ -177,27 +177,37 @@ class RVCService:
         """Start the service"""
         if not self.is_running:
             self.is_running = True
-            asyncio.create_task(self.worker_loop())
+            # Create a new event loop for the worker
+            loop = asyncio.new_event_loop()
+            asyncio.set_event_loop(loop)
+            
+            # Start the worker loop in the background
+            def run_worker():
+                loop.run_until_complete(self.worker_loop())
+                
+            self.worker_thread = threading.Thread(target=run_worker)
+            self.worker_thread.daemon = True
+            self.worker_thread.start()
             logger.info("RVC Service started")
+                
+        def stop(self):
+            """Stop the service"""
+            self.is_running = False
+            logger.info("RVC Service stopping...")
             
-    def stop(self):
-        """Stop the service"""
-        self.is_running = False
-        logger.info("RVC Service stopping...")
-        
-    async def submit_job(self, audio_data: np.ndarray, model_name: str, priority: int = 1) -> str:
-        """Submit a new job to the service"""
-        job_id = f"job_{int(time.time())}_{id(audio_data)}"
-        job = JobRequest(
-            id=job_id,
-            audio_data=audio_data,
-            model_name=model_name,
-            priority=priority
-        )
-        
-        if self.job_queue.add_job(job):
-            return job_id
-        return None
+        async def submit_job(self, audio_data: np.ndarray, model_name: str, priority: int = 1) -> str:
+            """Submit a new job to the service"""
+            job_id = f"job_{int(time.time())}_{id(audio_data)}"
+            job = JobRequest(
+                id=job_id,
+                audio_data=audio_data,
+                model_name=model_name,
+                priority=priority
+            )
+            
+            if self.job_queue.add_job(job):
+                return job_id
+            return None
 
 # Memory management utilities
 def cleanup_gpu_memory():