coco_pipe.decoding.persistence#

Resumable decoding-run artifact utilities.

Functions#

`redact_sensitive`(value)	Recursively redact credentials before persisting configs or reports.
`config_hash`(config)	Return a stable short hash for a run configuration.
`completed_for_config`(output_dir, config)	Return whether `output_dir` contains a successful matching run.
`load_completed_result_records`(output_dir, context)	Rehydrate aggregate rows for a safely resumed experiment.
`write_run_status`(root, status)	Write exactly one run-level success, partial, or failure marker.

Module Contents#

coco_pipe.decoding.persistence.redact_sensitive(value)#

Recursively redact credentials before persisting configs or reports.

Parameters:: value (Any)
Return type:: Any

coco_pipe.decoding.persistence.config_hash(config)#

Return a stable short hash for a run configuration.

Parameters:: config (collections.abc.Mapping[str, Any])
Return type:: str

coco_pipe.decoding.persistence.completed_for_config(output_dir, config)#

Return whether output_dir contains a successful matching run.

Parameters:

output_dir (str | pathlib.Path)
config (collections.abc.Mapping[str, Any])

Return type:

coco_pipe.decoding.persistence.load_completed_result_records(output_dir, context)#

Rehydrate aggregate rows for a safely resumed experiment.

Parameters:

output_dir (str | pathlib.Path)
context (collections.abc.Mapping[str, Any])

Return type:

list[dict[str, Any]]

coco_pipe.decoding.persistence.write_run_status(root, status)#

Write exactly one run-level success, partial, or failure marker.

Parameters:

root (str | pathlib.Path)
status (str)

Return type: