towhee.runtime.check_utils.check_node_iter

towhee.runtime.check_utils.check_node_iter(iter_type: str, iter_param: Dict[str, Any], inputs, outputs, all_inputs: Set[str])

Check if the iteration info is valid.

Parameters:

• iter_type (str) – The type of the iteration, such as ‘map’, ‘flat_map’, ‘filter’, ‘time_window’.

• iter_param (Dict[str, any]) – The parameter for the iteration.

• inputs (Tuple) – The inputs schema of the node.

• outputs (Tuple) – The inputs schema of the node.

• all_inputs (Set[str]) – The all inputs schema in the DAG util the node.