Differential D8684 Diff 40807 examples/docs_snippets/docs_snippets/guides/dagster/reexecution/unreliable_pipeline.py

Changeset View

Standalone View

Show All 14 Lines	if random() < failure_rate:
raise Exception("blah")		raise Exception("blah")


@solid()		@solid()
def unreliable_end(_, num):		def unreliable_end(_, num):
return		return


@pipeline(mode_defs=[ModeDefinition(resource_defs={"io_manager": fs_io_manager})])		@pipeline(
		mode_defs=[ModeDefinition(resource_defs={"io_manager": fs_io_manager})]
		)
def unreliable_pipeline():		def unreliable_pipeline():
unreliable_end(unreliable(unreliable_start()))		unreliable_end(unreliable(unreliable_start()))