Changeset View
Changeset View
Standalone View
Standalone View
examples/docs_snippets/docs_snippets/deploying/celery_pipeline.py
from dagster import ModeDefinition, default_executors, fs_io_manager, pipeline, solid | from dagster import ( | ||||
ModeDefinition, | |||||
default_executors, | |||||
fs_io_manager, | |||||
pipeline, | |||||
solid, | |||||
) | |||||
from dagster_celery import celery_executor | from dagster_celery import celery_executor | ||||
celery_mode_defs = [ | celery_mode_defs = [ | ||||
ModeDefinition( | ModeDefinition( | ||||
resource_defs={"io_manager": fs_io_manager}, | resource_defs={"io_manager": fs_io_manager}, | ||||
executor_defs=default_executors + [celery_executor], | executor_defs=default_executors + [celery_executor], | ||||
) | ) | ||||
] | ] | ||||
Show All 11 Lines |