dagster_celery_k8s_job_executor_quickstart_with_config.py

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