Skip to main content

Pipeline

A serving ensemble; submit with enqueue(), collect with wait(). Made by pipeline().

__init__​

__init__(self, /, *args, **kwargs)

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

enqueue​

enqueueenqueue(self, request: clika_runtime._core.runtime.Request) -> int

enqueue(self, request: clika_runtime._core.runtime.Request) -> int

Submit a request; returns the session id. Non-blocking.

run​

runrun(self, request: clika_runtime._core.runtime.Request) -> clika_runtime._core.runtime.Response

run(self, request: clika_runtime._core.runtime.Request) -> clika_runtime._core.runtime.Response

enqueue() then wait() in one call.

shutdown​

shutdownshutdown(self) -> None

shutdown(self) -> None

Drain in-flight work and stop; no new work is accepted after.

wait​

waitwait(self, session: int) -> clika_runtime._core.runtime.Response

wait(self, session: int) -> clika_runtime._core.runtime.Response

Block until the session completes; returns its Response.