hoops_ai.flowmanager.flow.Flow

class hoops_ai.flowmanager.flow.Flow(name, specifications, tasks=None)

Bases: object

Class to manage and orchestrate the execution of multiple Tasks.

Parameters:

• name (str)

• specifications (Dict[str, Any])

• tasks (List[Type[ParallelTask]] | None)

log_flow_summary()

Logs a summary of the flow execution, detailing each task’s inputs and outputs.

print_flow_task_registry()

Prints information about tasks specifically assigned to this flow. This shows only the tasks that will be executed in this flow instance.

process(inputs)

Executes the flow by running tasks in sequence based on their dependencies.

Parameters:

inputs (Dict[str, List[Any]]) – A dictionary of inputs available to the flow.

Returns:

An instance of FlowOutput containing results, errors, and logs.

Return type:

Tuple[FlowOutput, Dict[str, Any], str]