Differential D4918 Diff 25032 python_modules/libraries/dagster-celery-k8s/dagster_celery_k8s/config.py
Changeset View
Changeset View
Standalone View
Standalone View
python_modules/libraries/dagster-celery-k8s/dagster_celery_k8s/config.py
from dagster import Field, Noneable, StringSource | from dagster import Field, Noneable, StringSource | ||||
from dagster.core.host_representation.handle import IN_PROCESS_NAME | from dagster.core.host_representation import IN_PROCESS_NAME | ||||
from dagster.utils import merge_dicts | from dagster.utils import merge_dicts | ||||
from dagster_celery.executor import CELERY_CONFIG | from dagster_celery.executor import CELERY_CONFIG | ||||
from dagster_k8s import DagsterK8sJobConfig | from dagster_k8s import DagsterK8sJobConfig | ||||
CELERY_K8S_CONFIG_KEY = "celery-k8s" | CELERY_K8S_CONFIG_KEY = "celery-k8s" | ||||
def celery_k8s_config(): | def celery_k8s_config(): | ||||
▲ Show 20 Lines • Show All 69 Lines • Show Last 20 Lines |