Prefect Collection for interacting with Kubernetes: prefect-kubernetes

Archive
, ,
1

Docs

https://prefecthq.github.io/prefect-kubernetes/

Code

Examples

from prefect import flow
from prefect_kubernetes.credentials import KubernetesCredentials
from prefect_kubernetes.jobs import list_namespaced_job

@flow
def kubernetes_orchestrator():
    v1_job_list = list_namespaced_job(
        kubernetes_credentials=KubernetesCredentials.load("k8s-creds"),
        namespace="my-namespace",
    )