code: def get_async_pillar(opts, grains, minion_id, saltenv=None, ext=None, funcs=None,
                       pillar_override=None, pillarenv=None,
                       extra_minion_data=None):
      '''
      Return the correct pillar driver based on the file_client option
      '''
      file_client = opts['file_client']
      if opts.get('master_type') == 'disable' and file_client == 'remote':
          file_client = 'local'
      ptype = {
          'remote': AsyncRemotePillar,
          'local': AsyncPillar,
      }.get(file_client, AsyncPillar)
      return ptype(opts, grains, minion_id, saltenv, ext, functions=funcs,
                   pillar_override=pillar_override, pillarenv=pillarenv,
                   extra_minion_data=extra_minion_dataf get_async_pillar(opts, grains, minion_id, saltenv=None, ext=None, funcs=None,
                       pillar_override=None, pillarenv=None,
                       extra_minion_data=None):
      '''
      Return the correct pillar driver based on the file_client option
      '''
      file_client = opts['file_client']
      if opts.get('master_type') == 'disable' and file_client == 'remote':
          file_client = 'local'
      ptype = {
          'remote': AsyncRemotePillar,
          'local': AsyncPillar,
      }.get(file_client, AsyncPillar)
      return ptype(opts, grains, minion_id, saltenv, ext, functions=funcs,
                   pillar_override=pillar_override, pillarenv=pillarenv,
                   extra_minion_data=extra_minion_data)
docs: Return the correct pillar driver based on the file_client option