#NEWLINE# def clean( self ) : #NEWLINE# #INDENT# cleaned_data = super ( workflows . Action , self ) . clean ( ) #NEWLINE# job_type = cleaned_data . get ( 'job_type' , None ) #NEWLINE# if ( job_type != 'MapReduce.Streaming' ) : #NEWLINE# #INDENT# if ( 'streaming_mapper' in self . _errors ) : #NEWLINE# #INDENT# del self . _errors [ 'streaming_mapper' ] #NEWLINE# #UNINDENT# if ( 'streaming_reducer' in self . _errors ) : #NEWLINE# #INDENT# del self . _errors [ 'streaming_reducer' ] #NEWLINE# #UNINDENT# #UNINDENT# return cleaned_data