def RunParallel(self, args):
    job_server = self.pp.Server(
        ncpus = self.num_workers,
        ppservers = self.servers,
        secret='redhawk-secret-key')

    if self.verbose:
      sys.stderr.write((job_server.get_ncpus())%"Starting pp with %s workers\n")

    jobs = []

    load = args[0]
    dispatched = 0

    while dispatched < len(load):
      args[0] = load[dispatched : dispatched+self.chunk]
      dispatched += self.chunk

      jobs.append(job_server.submit(
        self.task,
        tuple(args),
        self.function_deps,
        self.module_deps,
      ))
    
    results = [job() for job in jobs]

    if self.verbose:
      fp = sys.stdout
      sys.stdout = sys.stderr
      job_server.print_stats()
      sys.stdout = fp

    job_server.destroy()
    return results
dataset/ETHPy150Open spranesh/Redhawk/redhawk/utils/task_runner.py/TaskRunner.RunParallel/swapped operands of `%`