code: def worker(work_unit):
      '''Expects a WorkUnit from coordinated, obtains a config, and runs
      traverse_extract_fetch
  
      '''
      if 'config' not in work_unit.spec:
          raise coordinate.exceptions.ProgrammerError(
              'could not run extraction without global config')
  
      web_conf = Config()
      unitconf = work_unit.spec['config']
      #logger.info(unitconf)
      with yakonfig.defaulted_config([coordinate, kvlayer, dblogger, web_conf],
                                     config=unitconf):
          traverse_extract_fetch(web_conf, work_unit.keyf worker(work_unit):
      '''Expects a WorkUnit from coordinated, obtains a config, and runs
      traverse_extract_fetch
  
      '''
      if 'config' not in work_unit.spec:
          raise coordinate.exceptions.ProgrammerError(
              'could not run extraction without global config')
  
      web_conf = Config()
      unitconf = work_unit.spec['config']
      #logger.info(unitconf)
      with yakonfig.defaulted_config([coordinate, kvlayer, dblogger, web_conf],
                                     config=unitconf):
          traverse_extract_fetch(web_conf, work_unit.key)
docs: Expects a WorkUnit from coordinated, obtains a config, and runs
      traverse_extract_fetch