examples: use LLMUserResponseAggregator with VAD
This commit is contained in:
@@ -10,8 +10,8 @@ from dailyai.services.elevenlabs_ai_service import ElevenLabsTTSService
|
|||||||
from dailyai.services.open_ai_services import OpenAILLMService
|
from dailyai.services.open_ai_services import OpenAILLMService
|
||||||
from dailyai.services.ai_services import FrameLogger
|
from dailyai.services.ai_services import FrameLogger
|
||||||
from dailyai.pipeline.aggregators import (
|
from dailyai.pipeline.aggregators import (
|
||||||
LLMAssistantContextAggregator,
|
LLMAssistantResponseAggregator,
|
||||||
LLMUserContextAggregator,
|
LLMUserResponseAggregator,
|
||||||
)
|
)
|
||||||
from runner import configure
|
from runner import configure
|
||||||
|
|
||||||
@@ -55,11 +55,9 @@ async def main(room_url: str, token):
|
|||||||
},
|
},
|
||||||
]
|
]
|
||||||
|
|
||||||
tma_in = LLMUserContextAggregator(
|
tma_in = LLMUserResponseAggregator(messages)
|
||||||
messages, transport._my_participant_id)
|
tma_out = LLMAssistantResponseAggregator(messages)
|
||||||
tma_out = LLMAssistantContextAggregator(
|
|
||||||
messages, transport._my_participant_id
|
|
||||||
)
|
|
||||||
pipeline = Pipeline(
|
pipeline = Pipeline(
|
||||||
processors=[
|
processors=[
|
||||||
fl,
|
fl,
|
||||||
|
|||||||
Reference in New Issue
Block a user