#NEWLINE# def __exit__( self , exception_type , exception_value , traceback ) : #NEWLINE# #INDENT# if ( self . output_message_bundle and self . output_message_bundle . messages ) : #NEWLINE# #INDENT# self . sink . context . workitem_commit_request . pubsub_messages . extend ( [ self . output_message_bundle ] ) #NEWLINE# #UNINDENT# self . output_message_bundle = None