#NEWLINE# def returner( ret ) : #NEWLINE# #INDENT# '\n    Return data to a redis data store\n    ' #NEWLINE# function = ret [ 'fun' ] #NEWLINE# log . debug ( 'Entering deploy_redis returner' ) #NEWLINE# log . debug ( 'function: {0}' . format ( function ) ) #NEWLINE# if ( not function . startswith ( 'deploy.' ) ) : #NEWLINE# #INDENT# return False #NEWLINE# #UNINDENT# ret_data = ret [ 'return' ] #NEWLINE# log . debug ( 'ret_data: {0}' . format ( ret_data ) ) #NEWLINE# minion = ret [ 'id' ] #NEWLINE# timestamp = time . time ( ) #NEWLINE# serv = _get_serv ( ) #NEWLINE# if ( function == 'deploy.sync_all' ) : #NEWLINE# #INDENT# for ( repo , functions ) in ret_data [ 'stats' ] . items ( ) : #NEWLINE# #INDENT# for ( func , data ) in functions . items ( ) : #NEWLINE# #INDENT# _record_function ( serv , func , timestamp , minion , data ) #NEWLINE# #UNINDENT# #UNINDENT# #UNINDENT# else : #NEWLINE# #INDENT# _record_function ( serv , function , timestamp , minion , ret_data )