#NEWLINE# def pipe( self , other_task ) : #NEWLINE# #INDENT# ' Add a pipe listener to the execution of this task. The\n        output of this task is required to be an iterable. Each item in\n        the iterable will be queued as the sole argument to an execution\n        of the listener task.\n\n        Can also be written as::\n\n            pipeline = task1 | task2\n        ' #NEWLINE# other_task . _source = other_task #NEWLINE# self . _listeners . append ( PipeListener ( other_task ) ) #NEWLINE# return other_task