def pipe(self, other_task):
        other_task._source = self
        self._listeners.append(PipeListener(other_task))
        return other_task
Add a pipe listener to the execution of this task. The
dataset/ETHPy150Open pudo/scrapekit/scrapekit/tasks.py/Task.pipe