Pipeline

Classes:

Pipeline(name)
PipelineFromRef(name)

Functions:

pipeline(function)

class curifactory.experimental.pipeline.Pipeline(name: str)

Attributes:

artifacts
name
outputs
parameters
reportables

Methods:

compute_hash()
consolidate_shared_artifacts()	Checks if any involved artifacts are in any way shared/can be explicitly pointed to, one from the other.
copy()
define()
ensure_context_copies()	An experiment definition, when taking other pipelines or artifacts as parameters, shouldn't mutate or alter where those pipelines/artifacts come from - so anything passed in gets automatically copied instead.
load_from_refname(refname)
log_verification_checks()
map()	Assumes define() has already run.
modify(**modifications)
report([template, save])
run()
verify()
visualize([dot])

Parameters:

name (str)

property artifacts

compute_hash()

consolidate_shared_artifacts()

Checks if any involved artifacts are in any way shared/can be explicitly pointed to, one from the other.

copy()

define()

Return type:

list[Artifact]

ensure_context_copies()

An experiment definition, when taking other pipelines or artifacts as parameters, shouldn’t mutate or alter where those pipelines/artifacts come from - so anything passed in gets automatically copied instead.

static load_from_refname(refname)

Parameters:

refname (str)

log_verification_checks()

map()

Assumes define() has already run.

modify(**modifications)

name: str

outputs: ArtifactList

property parameters: dict[str, Any]

report(template='default.html', save=False)

Parameters:

save (bool)

Return type:

str

property reportables

run()

verify()

visualize(dot=None, **kwargs)

class curifactory.experimental.pipeline.PipelineFromRef(name: str)

Methods:

define()

Parameters:

name (str)

define()

curifactory.experimental.pipeline.pipeline(function)