Differential D8684 Diff 40807 examples/docs_snippets/docs_snippets_tests/concepts_tests/io_management_tests/test_io_manager_per_output.py

Changeset View

Standalone View

	from tempfile import TemporaryDirectory			from tempfile import TemporaryDirectory

	from dagster import execute_pipeline			from dagster import execute_pipeline
	from docs_snippets.concepts.io_management.io_manager_per_output import my_pipeline			from docs_snippets.concepts.io_management.io_manager_per_output import (
				my_pipeline,
				)


	def test_io_manager_per_output():			def test_io_manager_per_output():
	with TemporaryDirectory() as tmpdir:			with TemporaryDirectory() as tmpdir:
	execute_pipeline(			execute_pipeline(
	my_pipeline,			my_pipeline,
	run_config={"resources": {"fs": {"config": {"base_dir": tmpdir}}}},			run_config={
				"resources": {"fs": {"config": {"base_dir": tmpdir}}}
				},
	)			)