Differential D8684 Diff 40807 examples/docs_snippets/docs_snippets/concepts/configuration/make_values_resource_config_schema.py

Changeset View

Standalone View

	from dagster import ModeDefinition, execute_pipeline, make_values_resource, pipeline, solid			from dagster import (
				ModeDefinition,
				execute_pipeline,
				make_values_resource,
				pipeline,
				solid,
				)


	@solid(required_resource_keys={"values"})			@solid(required_resource_keys={"values"})
	def solid1(context):			def solid1(context):
	context.log.info(f"my str: {context.resources.values['my_str']}")			context.log.info(f"my str: {context.resources.values['my_str']}")


	@solid(required_resource_keys={"values"})			@solid(required_resource_keys={"values"})
	def solid2(context):			def solid2(context):
	context.log.info(f"my int: {context.resources.values['my_int']}")			context.log.info(f"my int: {context.resources.values['my_int']}")


	@pipeline(			@pipeline(
	mode_defs=[			mode_defs=[
	ModeDefinition(resource_defs={"values": make_values_resource(my_str=str, my_int=int)})			ModeDefinition(
				resource_defs={
				"values": make_values_resource(my_str=str, my_int=int)
				}
				)
	]			]
	)			)
	def my_pipeline():			def my_pipeline():
	solid1()			solid1()
	solid2()			solid2()


	execute_pipeline(			execute_pipeline(
	my_pipeline, run_config={"resources": {"values": {"config": {"my_str": "foo", "my_int": 1}}}}			my_pipeline,
				run_config={
				"resources": {"values": {"config": {"my_str": "foo", "my_int": 1}}}
				},
	)			)