promptflow.executor.flow_validator 模块#

class promptflow.executor.flow_validator.FlowValidator#

基础类: object

这是一个验证类，旨在验证流程定义和输入数据的完整性和有效性。

static convert_flow_inputs_for_node(flow: Flow, node: 节点, inputs: Mapping[str, Any]) → Mapping[str, Any]#

过滤节点的流输入并根据类型解析值。

Parameters:

  • flow (Flow) – flow 参数是 Flow 类的一个实例。它表示包含节点和输入的流程或工作流。

  • node (Node) – node 参数是 Node 类的一个实例

  • inputs (Mapping[str, Any]) – 一个包含节点输入值的字典。键是输入变量的名称，值是对应的输入值

Returns:

节点所需的已解析流程输入仅由节点使用。

Return type:

映射[str, 任意]

static ensure_flow_inputs_type(flow: Flow, inputs: Mapping[str, Any], idx: Optional[int] = None) → Mapping[str, Any]#

确保输入已完成并且类型正确。如果无效，则引发异常。

Parameters:

  • flow (Flow) – flow 参数的类型是 Flow，表示一个流对象

  • inputs (Mapping[str, Any]) – 一个包含流程输入值的字典。键是流程输入的名称，值是对应的输入值

  • idx (可选[int]) – idx 参数是一个可选的整数，表示输入数据的行索引。它用于在输入数据出现错误时提供额外信息。

Returns:

更新后的输入，其中值根据flow对象中指定的预期类型进行了类型转换。

Return type:

映射[str, 任意]

static ensure_flow_valid_in_batch_mode(flow: Flow)#
static resolve_aggregated_flow_inputs_type(flow: Flow, inputs: Mapping[str, List[Any]]) → Mapping[str, Any]#
static resolve_flow_inputs_type(flow: Flow, inputs: Mapping[str, Any], idx: Optional[int] = None) → Mapping[str, Any]#

如果存在，按类型解析输入。忽略缺失的输入。

Parameters:

  • flow (Flow) – flow 参数的类型是 Flow，表示一个流对象

  • inputs (Mapping[str, Any]) – 一个包含流程输入值的字典。键是流程输入的名称，值是对应的输入值

  • idx (可选[int]) – idx 参数是一个可选的整数，表示输入数据的行索引。它用于在输入数据出现错误时提供额外的信息。

Returns:

更新后的输入值会根据flow对象中指定的预期类型进行类型转换。

Return type:

映射[str, 任意]