Differential D8684 Diff 40955 examples/docs_snippets/docs_snippets/legacy/data_science/iris_pipeline_2.py

Changeset View

Standalone View

	import dagstermill as dm			import dagstermill as dm
	from dagster import InputDefinition, ModeDefinition, fs_io_manager, pipeline			from dagster import InputDefinition, ModeDefinition, fs_io_manager, pipeline
	from dagster.utils import script_relative_path			from dagster.utils import script_relative_path
	from docs_snippets.legacy.data_science.download_file import download_file			from docs_snippets.legacy.data_science.download_file import download_file

	k_means_iris = dm.define_dagstermill_solid(			k_means_iris = dm.define_dagstermill_solid(
	"k_means_iris",			"k_means_iris",
	script_relative_path("iris-kmeans_2.ipynb"),			script_relative_path("iris-kmeans_2.ipynb"),
	input_defs=[InputDefinition("path", str, description="Local path to the Iris dataset")],			input_defs=[
				InputDefinition(
				"path", str, description="Local path to the Iris dataset"
				)
				],
	)			)


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