promptflow.executor.flow_validator 模块#

class promptflow.executor.flow_validator.FlowValidator#

基类：object

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

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

为节点过滤流输入并按类型解析值。

参数:

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

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

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

返回:

仅由节点解析的流输入。

返回类型:

Mapping[str, Any]

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

确保输入完整且类型正确。如果无效则引发异常。

参数:

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

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

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

返回:

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

返回类型:

Mapping[str, Any]

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]#

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

参数:

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

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

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

返回:

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

返回类型:

Mapping[str, Any]