Differential D8501 Diff 40096 python_modules/dagster-test/dagster_test/toys/repo.py

Changeset View

Standalone View

python_modules/dagster-test/dagster_test/toys/repo.py

	from dagster import repository			from dagster import repository
	from dagster_test.toys.asset_lineage import asset_lineage_partition_set, asset_lineage_pipeline			from dagster_test.toys.asset_lineage import asset_lineage_partition_set, asset_lineage_pipeline
	from dagster_test.toys.branches import branch_pipeline			from dagster_test.toys.branches import sleep_branch_job, sleep_failed_branch_job
	from dagster_test.toys.composition import composition			from dagster_test.toys.composition import composition_graph
	from dagster_test.toys.dynamic import dynamic_pipeline			from dagster_test.toys.dynamic import dynamic_pipeline
	from dagster_test.toys.error_monster import error_monster			from dagster_test.toys.error_monster import error_monster_job
	from dagster_test.toys.hammer import hammer_pipeline			from dagster_test.toys.hammer import hammer_pipeline
	from dagster_test.toys.log_asset import log_asset_pipeline			from dagster_test.toys.log_asset import log_asset_pipeline
	from dagster_test.toys.log_file import log_file_pipeline			from dagster_test.toys.log_file import log_file_pipeline
	from dagster_test.toys.log_s3 import log_s3_pipeline			from dagster_test.toys.log_s3 import log_s3_pipeline
	from dagster_test.toys.log_spew import log_spew			from dagster_test.toys.log_spew import log_spew
	from dagster_test.toys.longitudinal import longitudinal_pipeline			from dagster_test.toys.longitudinal import longitudinal_pipeline
	from dagster_test.toys.many_events import many_events			from dagster_test.toys.many_events import many_events
	from dagster_test.toys.retries import retry_pipeline			from dagster_test.toys.retries import retry_pipeline
	from dagster_test.toys.sleepy import sleepy_pipeline			from dagster_test.toys.sleepy import sleepy_pipeline
	from dagster_test.toys.unreliable import unreliable_pipeline			from dagster_test.toys.unreliable import unreliable_pipeline

	from .schedules import get_toys_schedules			from .schedules import get_toys_schedules
	from .sensors import get_toys_sensors			from .sensors import get_toys_sensors


	@repository			@repository
	def toys_repository():			def toys_repository():
	return (			return (
	[			[
	composition,			composition_graph,
	error_monster,			error_monster_job,
	hammer_pipeline,			hammer_pipeline,
	log_asset_pipeline,			log_asset_pipeline,
	log_file_pipeline,			log_file_pipeline,
	log_s3_pipeline,			log_s3_pipeline,
	log_spew,			log_spew,
	longitudinal_pipeline,			longitudinal_pipeline,
	many_events,			many_events,
	sleepy_pipeline,			sleepy_pipeline,
	retry_pipeline,			retry_pipeline,
	branch_pipeline,			sleep_branch_job,
				sleep_failed_branch_job,
	unreliable_pipeline,			unreliable_pipeline,
	dynamic_pipeline,			dynamic_pipeline,
	asset_lineage_pipeline,			asset_lineage_pipeline,
	asset_lineage_partition_set,			asset_lineage_partition_set,
				alangenfeldUnsubmitted Not Done Inline Actions request: comments on the ones you couldn't convert with why alangenfeld: request: comments on the ones you couldn't convert with why
	]			]
	+ get_toys_schedules()			+ get_toys_schedules()
	+ get_toys_sensors()			+ get_toys_sensors()
	)			)