Differential D8684 Diff 40976 examples/docs_snippets/docs_snippets/deploying/celery_pipeline.py

Changeset View

Standalone View

	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