Differential D7406 Diff 35370 python_modules/libraries/dagstermill/dagstermill/examples/repository.py

Changeset View

Standalone View

python_modules/libraries/dagstermill/dagstermill/examples/repository.py

	Show First 20 Lines • Show All 351 Lines • ▼ Show 20 Lines
	yield_obj = test_nb_solid("yield_obj")			yield_obj = test_nb_solid("yield_obj")


	@pipeline(mode_defs=default_mode_defs)			@pipeline(mode_defs=default_mode_defs)
	def yield_obj_pipeline():			def yield_obj_pipeline():
	yield_obj()			yield_obj()


				@pipeline(mode_defs=default_mode_defs)
				def retries_pipeline():
				test_nb_solid("raise_retry")()
				test_nb_solid("yield_retry")()


				@pipeline(mode_defs=default_mode_defs)
				def failure_pipeline():
				test_nb_solid("raise_failure")()
				test_nb_solid("yield_failure")()


	@repository			@repository
	def notebook_repo():			def notebook_repo():
	pipelines = [			pipelines = [
	bad_kernel_pipeline,			bad_kernel_pipeline,
	error_pipeline,			error_pipeline,
	hello_world_pipeline,			hello_world_pipeline,
	hello_world_with_custom_tags_and_description_pipeline,			hello_world_with_custom_tags_and_description_pipeline,
	hello_world_config_pipeline,			hello_world_config_pipeline,
	hello_world_explicit_yield_pipeline,			hello_world_explicit_yield_pipeline,
	hello_world_output_pipeline,			hello_world_output_pipeline,
	hello_logging_pipeline,			hello_logging_pipeline,
	resource_pipeline,			resource_pipeline,
	resource_with_exception_pipeline,			resource_with_exception_pipeline,
	add_pipeline,			add_pipeline,
	notebook_dag_pipeline,			notebook_dag_pipeline,
	reimport_pipeline,			reimport_pipeline,
	yield_3_pipeline,			yield_3_pipeline,
	yield_obj_pipeline,			yield_obj_pipeline,
				retries_pipeline,
				failure_pipeline,
	]			]
	if DAGSTER_PANDAS_PRESENT and SKLEARN_PRESENT and MATPLOTLIB_PRESENT:			if DAGSTER_PANDAS_PRESENT and SKLEARN_PRESENT and MATPLOTLIB_PRESENT:
	pipelines += [tutorial_pipeline]			pipelines += [tutorial_pipeline]

	return pipelines			return pipelines