class craftutils.observation.epoch.Pipeline(craftutils.observation.generic.Generic)

Public members

stage_output_dirs = True
Pipeline(do_runtime: list | str | None = None, **kwargs)

Initialize self. See help(type(self)) for accurate signature.

add_log(action: str, method=None, method_args=None, ...)
set_path(key: str, value: str)
classmethod stages()
classmethod enumerate_stages(show: bool = True)
query_stage(message: str, stage_name: str, n: float, ...)

Helper method for asking the user if we need to do this stage of processing. If self.do is True, skips the query and returns True.

check_done(stage: str)
pipeline(no_query: bool = False, **kwargs)

Performs the pipeline methods given in stages() for this instance.

load_output_file(**kwargs)
update_output_file()
update_param_file(param: str)