pipeline.py 文件源码

def run(self, count=None,  *args, **kwargs):
        from time import time

        self._start_time = time()

        count = count if count else self._count
        cb_count = self._callback_freq
        for i, row in enumerate(self._source_pipe):
            self.i = i
            if count and i == count:
                break

            if cb_count == 0:
                cb_count = self._callback_freq
                self._callback(self, i)
            cb_count -= 1