Back to Prefect

observer

docs/integrations/prefect-kubernetes/api-ref/prefect_kubernetes-observer.mdx

3.6.30.dev31.5 KB
Original Source

prefect_kubernetes.observer

Functions

configure <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-kubernetes/prefect_kubernetes/observer.py#L62" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
configure(settings: kopf.OperatorSettings, **_)

initialize_clients <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-kubernetes/prefect_kubernetes/observer.py#L67" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
initialize_clients(logger: kopf.Logger, **kwargs: Any)

cleanup_fn <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-kubernetes/prefect_kubernetes/observer.py#L81" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
cleanup_fn(logger: kopf.Logger, **kwargs: Any)

start_observer <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-kubernetes/prefect_kubernetes/observer.py#L795" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
start_observer()

Start the observer in a separate thread.

stop_observer <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-kubernetes/prefect_kubernetes/observer.py#L846" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
stop_observer()

Stop the observer thread.