ControllerFileStorage

class tierkreis.controller.storage.filestorage.ControllerFileStorage(workflow_id: UUID, name: str | None = None, tierkreis_directory: Path = PosixPath('/home/runner/.tierkreis/checkpoints'))

Bases: object

Methods

add_input
clean_graph_files
is_node_finished
is_node_started
is_output_ready
link_outputs
mark_node_finished
read_metadata
read_node_def
read_output
read_output_ports
read_worker_call_args
write_metadata
write_node_def
write_output
write_worker_call_args