observability.processor.trace_conversion.adapter.elasticsearch.nim_converter

Attributes

logger

Functions

convert_langchain_nim(...)

Convert a LangChain/LangGraph Nim trace source to a DFWESRecord.

Module Contents

logger

convert_langchain_nim(

trace_source: nat.plugins.data_flywheel.observability.schema.trace_container.TraceContainer,

) → nat.plugins.data_flywheel.observability.schema.sink.elasticsearch.dfw_es_record.DFWESRecord

Convert a LangChain/LangGraph Nim trace source to a DFWESRecord.

Args:

trace_source (TraceContainer): The trace source to convert

Returns:

DFWESRecord: The converted DFW record