Differential D8684 Diff 40955 examples/docs_snippets/docs_snippets/concepts/solids_pipelines/pipeline_execution.py

Changeset View

Standalone View

	Show First 20 Lines • Show All 44 Lines • ▼ Show 20 Lines
	@solid			@solid
	def total(in_1: int, in_2: int, in_3: int, in_4: int):			def total(in_1: int, in_2: int, in_3: int, in_4: int):
	return in_1 + in_2 + in_3 + in_4			return in_1 + in_2 + in_3 + in_4


	from dagster import ModeDefinition, fs_io_manager			from dagster import ModeDefinition, fs_io_manager

	# start_parallel_pipeline_marker			# start_parallel_pipeline_marker
	@pipeline(mode_defs=[ModeDefinition(resource_defs={"io_manager": fs_io_manager})])			@pipeline(
				mode_defs=[ModeDefinition(resource_defs={"io_manager": fs_io_manager})]
				)
	def parallel_pipeline():			def parallel_pipeline():
	total(return_one(), return_one(), return_one(), return_one())			total(return_one(), return_one(), return_one(), return_one())


	# end_parallel_pipeline_marker			# end_parallel_pipeline_marker

	# start_multiprocessing_marker			# start_multiprocessing_marker

	Show All 22 Lines