def create_multiprocessing(parallel_data, queue=None):
 reinit_crypto()
 parallel_data['opts']['output'] = 'json'
 cloud = Cloud(parallel_data['opts'])
 try:
  output = cloud.create(parallel_data['profile'], local_master=parallel_data['local_master'])
 except SaltCloudException as exc:
  log.error("Failed to deploy '{0[name]}'. Error: {1}".format(parallel_data, exc), exc_info_on_loglevel=logging.DEBUG)
  return {parallel_data['name']: {'Error': str(exc)}}
 if ((parallel_data['opts'].get('show_deploy_args', False) is False) and isinstance(output, dict)):
  output.pop('deploy_kwargs', None)
 return {parallel_data['name']: salt.utils.simple_types_filter(output)}

def create_multiprocessing ( parallel_data , queue = None ) : reinit_crypto ( ) parallel_data [ 'opts' ] [ 'output' ] = 'json' cloud = Cloud ( parallel_data [ 'opts' ] ) try : output = cloud . create ( parallel_data [ 'profile' ] , local_master = parallel_data [ 'local_master' ] ) except SaltCloudException as exc : log . error ( "Failed to deploy '{0[name]}'. Error: {1}" . format ( parallel_data , exc ) , exc_info_on_loglevel = logging . DEBUG ) return { parallel_data [ 'name' ] : { 'Error' : str ( exc ) } } if ( ( parallel_data [ 'opts' ] . get ( 'show_deploy_args' , False ) is False ) and isinstance ( output , dict ) ) : output . pop ( 'deploy_kwargs' , None ) 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 .