langchain_community.callbacks.tracers.wandb.RunProcessor

class langchain_community.callbacks.tracers.wandb.RunProcessor(wandb_module: Any, trace_module: Any)

处理LangChain Runs转换为WBTraceTree。

Methods

__init__(wandb_module, trace_module)
build_tree(runs)	从运行列表构建一个嵌套字典。 :param runs: 用于构建树的运行列表。 :return: 表示langchain Run的嵌套字典，其结构与WBTraceTree兼容。
flatten_run(run)	将嵌套运行对象展平为运行列表的实用程序。 :param run: 要展平的基本运行。 :return: 展平后的运行列表。
modify_serialized_iterative(runs[, ...])	用于修改运行字典列表的序列化字段的实用程序。 删除与exact_keys匹配的任何键以及包含任何partial_keys的键。 递归地将kwargs键下的字典移动到顶层。 将"id"字段更改为告诉WBTraceTree如何可视化运行的字符串"_kind"字段。将"serialized"字段提升到顶层。
process_model(run)	处理用于wandb模型字典序列化的实用程序。 :param run: 要处理的运行。 :return: 转换为传递给WBTraceTree的model_dict。
process_span(run)	将LangChain Run转换为W&B Trace Span。 :param run: 要转换的LangChain Run。 :return: 转换后的W&B Trace Span。
truncate_run_iterative(runs[, keep_keys])	实用程序，用于将一组运行字典截断，仅保留每个运行中指定的键。 :param runs: 要截断的运行列表。 :param keep_keys: 每个运行中要保留的键。 :return: 截断后的运行列表。

Parameters

• wandb_module (Any) –

• trace_module (Any) –

__init__(wandb_module: Any, trace_module: Any)

Parameters

• wandb_module (Any) –

• trace_module (Any) –

build_tree(runs: List[Dict[str, Any]]) → Dict[str, Any]

从运行列表构建一个嵌套字典。 :param runs: 用于构建树的运行列表。 :return: 表示langchain Run的嵌套字典，其结构与WBTraceTree兼容。

Parameters

runs (List[Dict[str, Any]]) –

Return type

Dict[str, Any]

flatten_run(run: Dict[str, Any]) → List[Dict[str, Any]]

将嵌套运行对象展平为运行列表的实用程序。 :param run: 要展平的基本运行。 :return: 展平后的运行列表。

Parameters

run (Dict[str, Any]) –

Return type

List[Dict[str, Any]]

modify_serialized_iterative(runs: List[Dict[str, Any]], exact_keys: Tuple[str, ...] = (), partial_keys: Tuple[str, ...] = ()) → List[Dict[str, Any]]

用于修改运行字典列表的序列化字段的实用程序。 删除与exact_keys匹配的任何键以及包含任何partial_keys的键。 递归地将kwargs键下的字典移动到顶层。 将”id”字段更改为告诉WBTraceTree如何可视化运行的字符串”_kind”字段。将”serialized”字段提升到顶层。

Parameters

• runs (List[Dict[str, Any]]) – 要修改的运行列表。

• exact_keys (Tuple[str, ...]) – 要从序列化字段中删除的键的元组。

• partial_keys (Tuple[str, ...]) – 要从序列化字段中删除的部分键的元组。

Returns

修改后的运行列表。

Return type

List[Dict[str, Any]]

process_model(run: Run) → Optional[Dict[str, Any]]

处理用于wandb模型字典序列化的实用程序。 :param run: 要处理的运行。 :return: 转换为传递给WBTraceTree的model_dict。

Parameters

run (Run) –

Return type

Optional[Dict[str, Any]]

process_span(run: Run) → Optional['Span']

将LangChain Run转换为W&B Trace Span。 :param run: 要转换的LangChain Run。 :return: 转换后的W&B Trace Span。

Parameters

run (Run) –

Return type

Optional[‘Span’]

truncate_run_iterative(runs: List[Dict[str, Any]], keep_keys: Tuple[str, ...] = ()) → List[Dict[str, Any]]

实用程序，用于将一组运行字典截断，仅保留每个运行中指定的键。 :param runs: 要截断的运行列表。 :param keep_keys: 每个运行中要保留的键。 :return: 截断后的运行列表。

Parameters

• runs (List[Dict[str, Any]]) –

• keep_keys (Tuple[str, ...]) –

Return type

List[Dict[str, Any]]