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, clean_ouput_dir=True)

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]