#NEWLINE# def __init__( self , shmem ) : #NEWLINE# #INDENT# AggregationTask . __init__ ( reader , shmem ) #NEWLINE# reader = wire . PackedMessageReader ( shmem ) #NEWLINE# self . left_inst = compat . pickle_load ( reader . string ( ) ) #NEWLINE# self . right_inst = compat . pickle_load ( reader . string ( ) )