code: def start_processor(self):
          
  
          if not self._wfp_process:
  
              try:
  
                  self._prof.prof('creating wfp process', uid=self._uid)
                  self._wfp_process = Process(
                      target=self._wfp, name='wfprocessor')
  
                  self._enqueue_thread = None
                  self._dequeue_thread = None
                  self._enqueue_thread_terminate = threading.Event()
                  self._dequeue_thread_terminate = threading.Event()
  
                  self._wfp_terminate = Event()
                  self._logger.info('Starting WFprocessor process')
                  self._prof.prof('starting wfp process', uid=self._uid)
                  self._wfp_process.start()
  
                  return True
  
              except Exception, ex:
  
                  self._logger.exception('WFprocessor not started')
                  self.terminate_processor()
                  raise
  
          else:
              self._logger.warn(
                  'Wfp process already running, attempted to restart!')
docs: **Purpose**: Method to start the wfp process. The wfp function
          is not to be accessed directly. The function is started in a separate
          process using this method.