#NEWLINE# def __init__( self , topic_partition ) : #NEWLINE# #INDENT# super ( FutureProduceResult , self ) . __init__ ( ) #NEWLINE# self . topic_partition = self #NEWLINE# self . _latch = threading . Event ( )