hoops_ai.flowmanager.ParallelTask

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

Bases: ABC

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)

execute(item_index, item)

Executes the task logic on a single item.

Parameters:

• item_index (int)

• item (Any)

Return type:

Dict[str, Any]

finalize()

log_error_summary()

process_errors()

abstract process_item(item)

Parameters:

item (Any)

Return type:

Any | None

classmethod progress_description()

Return type:

str

save_error_summary()

task_inputs: List[str] = []

task_outputs: List[str] = []