fix type issue

ffmpeg_converter_actor.py

@@ -47,12 +47,12 @@ class FFMpegConverterActor:
     async def push_chunk(self, chunk):
         try:
             self.input_pipe.write(chunk)
-            # await self.input_pipe.drain()
+            await self.input_pipe.drain()
         except BrokenPipeError:
             # If the pipe is broken, restart the process.
             await self.start_process()
             self.input_pipe.write(chunk)
-            # await self.input_pipe.drain()
+            await self.input_pipe.drain()
 
     # def has_processed_all_data(self):
     #     return self.process.poll() is not None

respond_to_prompt_actor.py

@@ -6,6 +6,7 @@ from text_to_speech_service import TextToSpeechService
 from chat_service import ChatService
 import asyncio
 # from ray.actor import ActorHandle
+from ffmpeg_converter_actor import FFMpegConverterActor
 
 @ray.remote
 class PromptToLLMActor:
@@ -78,7 +79,7 @@ class SpeechToSpeakerActor:
 
 @ray.remote
 class SpeechToConverterActor:
-    def __init__(self, input_queue:Queue, ffmpeg_converter_actor:Queue):
+    def __init__(self, input_queue:Queue, ffmpeg_converter_actor:FFMpegConverterActor):
         load_dotenv()
         self.input_queue = input_queue
         self.ffmpeg_converter_actor = ffmpeg_converter_actor