def destroy_multiprocessing(parallel_data, queue=None):
 reinit_crypto()
 parallel_data['opts']['output'] = 'json'
 clouds = salt.loader.clouds(parallel_data['opts'])
 try:
  fun = clouds['{0}.destroy'.format(parallel_data['driver'])]
  with context.func_globals_inject(fun, __active_provider_name__=':'.join([parallel_data['alias'], parallel_data['driver']])):
   output = fun(parallel_data['name'])
 except SaltCloudException as exc:
  log.error('Failed to destroy {0}. Error: {1}'.format(parallel_data['name'], exc), exc_info_on_loglevel=logging.DEBUG)
  return {parallel_data['name']: {'Error': str(exc)}}
 return {parallel_data['name']: salt.utils.simple_types_filter(output)}

def destroy_multiprocessing ( parallel_data , queue = None ) : reinit_crypto ( ) parallel_data [ 'opts' ] [ 'output' ] = 'json' clouds = salt . loader . clouds ( parallel_data [ 'opts' ] ) try : fun = clouds [ '{0}.destroy' . format ( parallel_data [ 'driver' ] ) ] with context . func_globals_inject ( fun , __active_provider_name__ = ':' . join ( [ parallel_data [ 'alias' ] , parallel_data [ 'driver' ] ] ) ) : output = fun ( parallel_data [ 'name' ] ) except SaltCloudException as exc : log . error ( 'Failed to destroy {0}. Error: {1}' . format ( parallel_data [ 'name' ] , exc ) , exc_info_on_loglevel = logging . DEBUG ) return { parallel_data [ 'name' ] : { 'Error' : str ( exc ) } } return { parallel_data [ 'name' ] : salt . utils . simple_types_filter ( output ) }
this function will be called from another process when running a map in parallel mode .