Differential D7406 Diff 35370 python_modules/libraries/dagstermill/dagstermill/examples/repository.py
Changeset View
Changeset View
Standalone 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 |