def put(self, obj):
        active_outputs = 0
        for output in self.outputs:
            if not output.closed():
                output.put(obj)
                active_outputs += 1

        # This is not very safe, as run() might not expect it
        if not active_outputs:
            raise NodeFinished
Put row into all output pipes.
dataset/ETHPy150Open Stiivi/brewery/brewery/nodes/base.py/Node.put