#NEWLINE# def send_batch( self , events ) : #NEWLINE# #INDENT# '\n        Get all events\n        ' #NEWLINE# r = redis . StrictRedis ( host = self . redis_host , port = self . redis_port ) #NEWLINE# pipe = r . pipeline ( ) #NEWLINE# for event_tuple in events : #NEWLINE# #INDENT# event = event_tuple [ 0 ] #NEWLINE# pipe . set ( '{0}' . format ( event [ 'data' ] [ 'jid' ] ) , event [ 'data' ] [ 'return' ] ) #NEWLINE# #UNINDENT# pipe . execute ( )