Langchain

class pipecat.processors.frameworks.langchain.LangchainProcessor(chain, transcript_key='input')[source]

Bases: FrameProcessor

Parameters:
  • chain (langchain_core.runnables.Runnable)

  • transcript_key (str)

set_participant_id(participant_id)[source]
Parameters:

participant_id (str)

async process_frame(frame, direction)[source]
Parameters:
  • frame (Frame)

  • direction (FrameDirection)