def run_function_over_input(self):
        start = datetime.datetime.now()

        self.progress = self.options.progress

        files = glob.glob(self.options.datadir + self.options.dataglob)
        pool = vimap.pool.fork_identical(
            self.worker_fcn,
            num_workers=self.options.num_workers,
        )

        for input, output in pool.imap(files).zip_in_out():
            if self.progress:
                print "Processing", input

            yield input, output

        end = datetime.datetime.now()

        if self.progress:
            print "\n Started at: ", start.isoformat()
            print "Finished at: ", end.isoformat()
            print "Processed {0} files in {1} seconds".format(
                len(files), (end - start).seconds)
Sends a SIGTRAP to the pid and returns a console UI handler.
dataset/ETHPy150Open gatoatigrado/vimap/vimap/ext/file_runner.py/FileRunner.run_function_over_input--crossover with--dataset/ETHPy150Open dieseldev/diesel/diesel/console.py/console_for