wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fixing up the response

Browse Source
This commit is contained in:
Moishe Lettvin
2023-12-27 19:11:49 -05:00
parent 927aaadf39
commit 3f1bb7cac1
2 changed files with 7 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/dailyai/async_processor/async_processor.py
View File

@@ -214,11 +214,6 @@ class AsyncProcessor:
pass
class ResponseArgs(TypedDict):
services: AIServiceConfig
message_handler: MessageHandler
output_queue: Queue
class Response(AsyncProcessor):
def __init__(
self,
@@ -234,8 +229,6 @@ class Response(AsyncProcessor):
self.chunks_in_preparation = Queue()
# self.sprite_loader = sprite_loader.SpriteLoader()
self.llm_responses: list[str] = []
def get_preparation_iterator(self) -> Iterator:

10
src/dailyai/orchestrator.py
View File

@@ -69,6 +69,7 @@ class Orchestrator(EventHandler):
self.story_started = False
self.message_handler = message_handler
self.conversation_processors: ConversationProcessorCollection = conversation_processors
if conversation_processors.introduction is not None:
intro = conversation_processors.introduction(
@@ -303,7 +304,10 @@ class Orchestrator(EventHandler):
self.display_thinking()
self.message_handler.add_user_message(fragment)
new_response = Response(self.services, self.message_handler, self.output_queue)
response_type = self.conversation_processors.response or Response
new_response: Response = response_type(
self.services, self.message_handler, self.output_queue
)
new_response.set_state_callback(
AsyncProcessorState.DONE, self.on_response_played
)
@@ -360,7 +364,7 @@ class Orchestrator(EventHandler):
"sc-listen-1",
"sc-listen-1",
]
#self.display_images(listening_images)
# self.display_images(listening_images)
def display_thinking(self):
thinking_images = [
@@ -373,7 +377,7 @@ class Orchestrator(EventHandler):
"sc-think-4",
"sc-think-4",
]
#self.display_images(thinking_images)
# self.display_images(thinking_images)
def action(self):
self.logger.info("starting camera thread")