dagster_k8s_job_executor_quickstart_example.py

1from dagster import job, op
2from dagster_k8s import k8s_job_executor
3
4@op
5def hello_k8s():
6    return "Hello, Kubernetes!"
7
8@job(executor_def=k8s_job_executor)
9def k8s_example_job():
10    hello_k8s()