#NEWLINE# def pipeline( self , pipeline , pipeline_index = 0 , * args , **kwargs ) : #NEWLINE# #INDENT# out = self . run_pipeline ( pipeline , pipeline_index , * args , ** self ) #NEWLINE# if ( not isinstance ( out , dict ) ) : #NEWLINE# #INDENT# return out #NEWLINE# #UNINDENT# user = out . get ( 'user' ) #NEWLINE# if user : #NEWLINE# #INDENT# user . social_user = out . get ( 'social' ) #NEWLINE# user . is_new = out . get ( 'is_new' ) #NEWLINE# #UNINDENT# return user