Differential D8684 Diff 40807 examples/docs_snippets/docs_snippets/legacy/data_science/iris_pipeline.py

Changeset View

Standalone View

	import dagstermill as dm			import dagstermill as dm
	from dagster import ModeDefinition, fs_io_manager, local_file_manager, pipeline			from dagster import (
				ModeDefinition,
				fs_io_manager,
				local_file_manager,
				pipeline,
				)
	from dagster.utils import script_relative_path			from dagster.utils import script_relative_path

	k_means_iris = dm.define_dagstermill_solid(			k_means_iris = dm.define_dagstermill_solid(
	"k_means_iris", script_relative_path("iris-kmeans.ipynb")			"k_means_iris", script_relative_path("iris-kmeans.ipynb")
	)			)


	@pipeline(			@pipeline(
	mode_defs=[			mode_defs=[
	ModeDefinition(			ModeDefinition(
	resource_defs={"io_manager": fs_io_manager, "file_manager": local_file_manager}			resource_defs={
				"io_manager": fs_io_manager,
				"file_manager": local_file_manager,
				}
	)			)
	]			]
	)			)
	def iris_pipeline():			def iris_pipeline():
	k_means_iris()			k_means_iris()