tensorbay.healthcheck.pipeline

Pipeline and PipelineForIterable.

Pipeline runs registered checker functions while healthchecking. PipelineForIterable is a healthcheck pipeline to processes iterable objects.

Checker functions can be registered to the healthcheck pipeline by Pipeline.register() or PipelineForIterable.register.

class tensorbay.healthcheck.pipeline.Pipeline[source]

Bases: Generic[tensorbay.healthcheck.pipeline._A, tensorbay.healthcheck.pipeline._R]

Pipeline is a healthcheck pipeline to run registered checker functions.

register(checker: Callable[[tensorbay.healthcheck.pipeline._A], Iterator[tensorbay.healthcheck.pipeline._R]]) → Callable[[tensorbay.healthcheck.pipeline._A], Iterator[tensorbay.healthcheck.pipeline._R]][source]

Decorator function to register checkers into pipeline.

Parameters: checker – The checker function needs to be registered.
Returns: The checker function unchanged.

copy() → tensorbay.healthcheck.pipeline._S[source]

Copy method to get a shallow copy of pipeline.

Returns: A shallow copy of the pipeline.

class tensorbay.healthcheck.pipeline.PipelineForIterable[source]

Bases: tensorbay.healthcheck.pipeline.Pipeline[tensorbay.healthcheck.pipeline._A, tensorbay.healthcheck.pipeline._R]

Healthcheck pipeline for processing iterable objects.