def __init__(self, worker_count=None, *args, **kwargs):
    super(MultiProcessTaskExecutor, self).__init__(*args, **kwargs)
    self.worker_count = worker_count
    self._waiting_deferreds = {}

    try:
      self._pool = multiprocessing.Pool(processes=self.worker_count,
                                        initializer=_task_initializer)
    except OSError as e: # pragma: no cover
      print e
      print 'Unable to initialize multiprocessing!'
      if sys.platform == 'cygwin':
        print ('Cygwin has known issues with multiprocessing and there\'s no '
               'workaround. Boo!')
      print 'Try running with -j1 to disable multiprocessing'
      raise
Enable a job in the scheduler.
dataset/ETHPy150Open google/anvil-build/anvil/task.py/MultiProcessTaskExecutor.__init__--crossover with--dataset/ETHPy150Open saltstack/salt/salt/utils/schedule.py/Schedule.enable_job