Hi! Is there some way to stop pipeline execution, if on some step we decide this. f.e. no data in table.

@solid(output_defs=[OutputDefinition(Dict, 'data', is_required=False)])
def solid_1(context):
	#read data code
	if data:
		return dict()
	else:
		return None #how stop pipeline here?
	
@solid(input_defs=[InputDefinition('data', Dict)])
def solid_2(context,data):
	return dict()

Thanks!

you can

raise Failure()

raise - how to understand witch of two situations are real (exception and raise)? I think this way is dead end. conditional_execution - may be. I can route to "end" solid if have to stop pipe line. Thank you!