Differential D8684 Diff 40813 examples/docs_snippets/docs_snippets_tests/concepts_tests/solids_pipelines_tests/test_pipeline_execution.py

Changeset View

Standalone View

	Show All 16 Lines

	def test_solid_selection():			def test_solid_selection():
	execute_subset()			execute_subset()


	def test_multiprocess_yaml():			def test_multiprocess_yaml():
	with open(			with open(
	file_relative_path(			file_relative_path(
	__file__, "../../../docs_snippets/concepts/solids_pipelines/multiprocessing.yaml"			__file__,
				"../../../docs_snippets/concepts/solids_pipelines/multiprocessing.yaml",
	),			),
	"r",			"r",
	) as fd:			) as fd:
	run_config = yaml.safe_load(fd.read())			run_config = yaml.safe_load(fd.read())

	with instance_for_test() as instance:			with instance_for_test() as instance:
	assert execute_pipeline(			assert execute_pipeline(
	reconstructable(parallel_pipeline), run_config=run_config, instance=instance			reconstructable(parallel_pipeline),
				run_config=run_config,
				instance=instance,
	).success			).success


	def test_multiprocess_pipeline():			def test_multiprocess_pipeline():
	execute_multiprocessing()			execute_multiprocessing()