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)[source]#

Decorator function to register checkers into pipeline.

Parameters

checker (Callable[[tensorbay.healthcheck.pipeline._A], Iterator[tensorbay.healthcheck.pipeline._R]]) – The checker function needs to be registered.

Returns

The checker function unchanged.

Return type

Callable[[tensorbay.healthcheck.pipeline._A], Iterator[tensorbay.healthcheck.pipeline._R]]

copy()[source]#

Copy method to get a shallow copy of pipeline.

Returns

A shallow copy of the pipeline.

Parameters

self (tensorbay.healthcheck.pipeline._S) –

Return type

tensorbay.healthcheck.pipeline._S

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.