Differential D8684 Diff 40813 examples/docs_snippets/docs_snippets/concepts/solids_pipelines/composite_solids.py

Changeset View

Standalone View

	# pylint: disable=unused-argument			# pylint: disable=unused-argument

	from dagster import InputDefinition, composite_solid, pipeline, repository, solid			from dagster import (
				InputDefinition,
				composite_solid,
				pipeline,
				repository,
				solid,
				)


	@solid			@solid
	def my_solid():			def my_solid():
	pass			pass


	@solid			@solid
	Show All 39 Lines

	# end_composite_solid_config_marker			# end_composite_solid_config_marker

	# start_composite_mapping_marker			# start_composite_mapping_marker


	def config_mapping_fn(config):			def config_mapping_fn(config):
	x = config["x"]			x = config["x"]
	return {"add_n": {"config": {"n": x}}, "multiply_by_m": {"config": {"m": x}}}			return {
				"add_n": {"config": {"n": x}},
				"multiply_by_m": {"config": {"m": x}},
				}


	@composite_solid(			@composite_solid(
	config_fn=config_mapping_fn,			config_fn=config_mapping_fn,
	config_schema={"x": int},			config_schema={"x": int},
	input_defs=[InputDefinition("number", int)],			input_defs=[InputDefinition("number", int)],
	)			)
	def add_x_multiply_by_x(number):			def add_x_multiply_by_x(number):
	Show All 19 Lines