latent.registry.tasks¶

Task registry for pipeline visualization and metadata tracking.

Classes¶

TaskMetadata(name: str, flow_name: str, inputs: list[str] = list(), outputs: list[str] = list())

Metadata for a registered task.

TaskRegistry()

Registry for tracking task metadata and dependencies.

clear()

Clear the registry (useful for testing).

print_ascii()

Render pipeline topology in terminal.

register(name: str, flow_name: str, inputs: list[str], outputs: list[str])

Register a task with the registry.

Args: name: Task name flow_name: Name of the flow the task belongs to inputs: List of input dataset names outputs: List of output dataset names