Code fixing

app.py

@@ -553,6 +553,10 @@ class DiarizationHandler(AsyncStreamHandler):
     def __init__(self, diarization_system):
         super().__init__()
         self.diarization_system = diarization_system
+        
+    def copy(self):
+        # Return a fresh handler for each new stream connection
+        return DiarizationHandler(self.diarization_system)
     
     async def emit(self):
         """Not used in this implementation"""