Update pipeline.py

pipeline.py

@@ -50,6 +50,9 @@ class SpeechAnnotationPipeline:
                 "m4a":"audio/mp4","flac":"audio/flac","ogg":"audio/ogg"}.get(ext,"audio/wav")
         params = {"model":"nova-2","diarize":"true","punctuate":"true",
                   "utterances":"true","smart_format":"true"}
+        if num_speakers and num_speakers > 0:
+            params["diarize_version"] = "latest"
+            params["num_speakers"] = str(num_speakers)
         headers = {"Authorization": f"Token {DEEPGRAM_API_KEY}", "Content-Type": mime}
         response = httpx.post("https://api.deepgram.com/v1/listen",
                               params=params, headers=headers,