Differential D5721 Diff 28962 python_modules/dagster-test/dagster_test/toys/dynamic.py

Changeset View

Standalone View

	Show All 26 Lines
	@solid(output_defs=[DynamicOutputDefinition()])			@solid(output_defs=[DynamicOutputDefinition()])
	def emit(_):			def emit(_):
	for i in range(3):			for i in range(3):
	yield DynamicOutput(value=i, mapping_key=str(i))			yield DynamicOutput(value=i, mapping_key=str(i))


	@pipeline			@pipeline
	def dynamic_pipeline():			def dynamic_pipeline():
	multiply_by_two(multiply_inputs(emit(), emit_ten()))			# pylint: disable=no-member
				emit().forEach(lambda num: multiply_by_two(multiply_inputs(num, emit_ten())))