nat.plugins.data_flywheel.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