original_docstring: Creates an extraction worker object.
  
      Args:
        worker_number: number that identifies the worker.
        options: the command line arguments (instance of argparse.Namespace).
  
      Returns:
        An extraction worker (instance of worker.ExtractionWorker).
      
docstring: Creates an extraction worker object.
docstring_tokens: Creates an extraction worker object .
code: def _CreateExtractionWorker(self, worker_number, options):
      """Creates an extraction worker object.
  
      Args:
        worker_number: number that identifies the worker.
        options: the command line arguments (instance of argparse.Namespace).
  
      Returns:
        An extraction worker (instance of worker.ExtractionWorker).
      """
      # Set up a simple XML RPC server for the worker for status indications.
      # Since we don't know the worker's PID for now we'll set the initial port
      # number to zero and then adjust it later.
      proxy_server = rpc_proxy.StandardRpcProxyServer()
      extraction_worker = self._engine.CreateExtractionWorker(
          worker_number, rpc_proxy=proxy_server)
  
      extraction_worker.SetDebugMode(self._debug_mode)
      extraction_worker.SetSingleProcessMode(self._single_process_mode)
  
      open_files = getattr(options, 'open_files', False)
      extraction_worker.SetOpenFiles(open_files)
  
      if getattr(options, 'os', None):
        mount_path = getattr(options, 'filename', None)
        extraction_worker.SetMountPath(mount_path)
  
      filter_query = getattr(options, 'filter', None)
      if filter_query:
        filter_object = pfilter.GetMatcher(filter_query)
        extraction_worker.SetFilterObject(filter_object)
  
      text_prepend = getattr(options, 'text_prepend', None)
      extraction_worker.SetTextPrepend(text_prepend)
  
      return extraction_worker
code_tokens: def _CreateExtractionWorker ( self , worker_number , options ) : proxy_server = rpc_proxy . StandardRpcProxyServer ( ) extraction_worker = self . _engine . CreateExtractionWorker ( worker_number , rpc_proxy = proxy_server ) extraction_worker . SetDebugMode ( self . _debug_mode ) extraction_worker . SetSingleProcessMode ( self . _single_process_mode ) open_files = getattr ( options , 'open_files' , False ) extraction_worker . SetOpenFiles ( open_files ) if getattr ( options , 'os' , None ) : mount_path = getattr ( options , 'filename' , None ) extraction_worker . SetMountPath ( mount_path ) filter_query = getattr ( options , 'filter' , None ) if filter_query : filter_object = pfilter . GetMatcher ( filter_query ) extraction_worker . SetFilterObject ( filter_object ) text_prepend = getattr ( options , 'text_prepend' , None ) extraction_worker . SetTextPrepend ( text_prepend ) return extraction_worker
short_docstring: Creates an extraction worker object.
short_docstring_tokens: Creates an extraction worker object .
comment: """Creates an extraction worker object.
  
      Args:
        worker_number: number that identifies the worker.
        options: the command line arguments (instance of argparse.Namespace).
  
      Returns:
        An extraction worker (instance of worker.ExtractionWorker).
      """$SEP$# Set up a simple XML RPC server for the worker for status indications.$SEP$# Since we don't know the worker's PID for now we'll set the initial port$SEP$# number to zero and then adjust it later.