aqueduct-v01-blog-fn-def.py

@op 
def clean_data(raw_data):
	# Clean raw_data.
	return cleaned_data

@op
def make_predictions(cleaned_data):
	# Make my predictions on `inputs`
	return predictions