old_contents: import os
  import sys
  # Append .. to sys path
  sys.path.append(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
  import multiscanner
  
  from celery import Celery
  
  app = Celery('celery_worker', broker='pyamqp://guest@localhost//')
  
  @app.task
  def multiscanner_celery(filelist, config=multiscanner.CONFIG):
      '''
      TODO: Add other ars + config options...
      This function essentially takes in a file list and runs
      multiscanner on them. Results are stored in the
      storage configured in storage.ini.
  
      Usage:
      from celery_worker import multiscanner_celery
      multiscanner_celery.delay([list, of, files, to, scan])
      '''
      storage_conf = multiscanner.common.get_storage_config_path(config)
      storage_handler = multiscanner.storage.StorageHandler(configfile=storage_conf)
  
      resultlist = multiscanner.multiscan(filelist, configfile=config)
      results = multiscanner.parse_reports(resultlist, python=True)
  
      storage_handler.store(results, wait=False)
      storage_handler.close()
      return results
  
new_contents: import os
  import sys
  # Append .. to sys path
  sys.path.append(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
  import multiscanner
  
  from celery import Celery
  
  RABBIT_USER = 'guest'
  RABBIT_HOST = 'localhost'
  
  app = Celery('celery_worker', broker='pyamqp://%s@%s//' % (RABBIT_USER, RABBIT_HOST))
  
  @app.task
  def multiscanner_celery(filelist, config=multiscanner.CONFIG):
      '''
      TODO: Figure out how to do batching.
      TODO: Add other ars + config options...
      This function essentially takes in a file list and runs
      multiscanner on them. Results are stored in the
      storage configured in storage.ini.
  
      Usage:
      from celery_worker import multiscanner_celery
      multiscanner_celery.delay([list, of, files, to, scan])
      '''
      storage_conf = multiscanner.common.get_storage_config_path(config)
      storage_handler = multiscanner.storage.StorageHandler(configfile=storage_conf)
  
      resultlist = multiscanner.multiscan(filelist, configfile=config)
      results = multiscanner.parse_reports(resultlist, python=True)
  
      storage_handler.store(results, wait=False)
      storage_handler.close()
      return results
  
subject: Move rabbit vars to globals