hoops_ai.flowmanager.flow.FlowOutput

class hoops_ai.flowmanager.flow.FlowOutput(flow_spec, task_instances, flow_name, time_to_process)

Bases: object

Class to encapsulate the results, errors, and logs from the Flow execution.

Parameters:

• flow_spec (Dict[str, Any])

• task_instances (List[ParallelTask])

• flow_name (str)

• time_to_process (float)

generate_flow_summary(file_path)

Generates a JSON summary of the flow execution and saves it to a file.

Parameters:

file_path (str) – The path to the file where the JSON summary will be saved.

summary()

Generates a summary of the flow execution.

Returns:

A formatted string summarizing the execution results.

Return type:

str

flow_name: str

flow_spec: Dict[str, Any]

task_instances: List[ParallelTask]

time_to_process: float