Differential D8684 Diff 40807 examples/docs_snippets/docs_snippets/concepts/solids_pipelines/order_based_dependency_pipeline.py

Changeset View

Standalone View

	Show All 10 Lines


	# start_marker			# start_marker
	from dagster import InputDefinition, Nothing, pipeline, solid			from dagster import InputDefinition, Nothing, pipeline, solid


	@solid			@solid
	def create_table_1() -> Nothing:			def create_table_1() -> Nothing:
	get_database_connection().execute("create table_1 as select * from some_source_table")			get_database_connection().execute(
				"create table_1 as select * from some_source_table"
				)


	@solid(input_defs=[InputDefinition("start", Nothing)])			@solid(input_defs=[InputDefinition("start", Nothing)])
	def create_table_2():			def create_table_2():
	get_database_connection().execute("create table_2 as select * from table_1")			get_database_connection().execute(
				"create table_2 as select * from table_1"
				)


	@pipeline			@pipeline
	def nothing_dependency_pipeline():			def nothing_dependency_pipeline():
	create_table_2(create_table_1())			create_table_2(create_table_1())


	# end_marker			# end_marker