hoops_ai.flowmanager.sequential_task

Classes

SequentialTask([logger, specifications, ...])

Base class for parallel tasks.

class hoops_ai.flowmanager.sequential_task.SequentialTask(logger=None, specifications=None, flow_name=None, max_retries=0)

Bases: BaseTask

Base class for parallel tasks. Users should subclass this and implement the process_item method.

Parameters:

• logger (Logger | None)

• specifications (Dict[str, Any] | None)

• flow_name (str | None)

• max_retries (int)

errors: List[Dict[str, Any]]

execute(inputs)

Executes the sequential task logic.

Parameters:

inputs (Dict[str, Any]) – A dictionary containing the required inputs.

Return type:

None

logs: List[str]

outputs: Dict[str, Any] = {}

process(inputs)

User-defined method to process inputs and produce outputs.

Parameters:

inputs (Dict[str, Any]) – A dictionary containing the required inputs.

Returns:

A dictionary of outputs.

Return type:

Dict[str, Any]

results: List[Dict[str, Any]]

task_inputs: List[str] = []

task_outputs: List[str] = []