dagster_celery_k8s_job_executor_quickstart_example.py

1from dagster import job, op
2from dagster_celery_k8s import celery_k8s_job_executor
3
4@op
5def hello_world():
6    return "Hello, Celery on Kubernetes!"
7
8@job(
9    executor_def=celery_k8s_job_executor,
10    config={
11        "execution": {
12            "config": {
13                "job_image": "my-docker-image:latest",
14                "job_namespace": "dagster",
15                "broker": "pyamqp://guest@localhost//",
16                "backend": "rpc://",
17            }
18        }
19    }
20)
21def celery_k8s_job():
22    hello_world()