def fire_args(opts, jid, tag_data, prefix=''):
 try:
  tag_suffix = [jid, 'args']
 except NameError:
  pass
 else:
  try:
   _event = get_master_event(opts, opts['sock_dir'], listen=False)
   tag = tagify(tag_suffix, prefix)
   _event.fire_event(tag_data, tag=tag)
  except Exception as exc:
   log.warning('Failed to fire args event %s with data %s: %s', tag, tag_data, exc)

def fire_args ( opts , jid , tag_data , prefix = '' ) : try : tag_suffix = [ jid , 'args' ] except NameError : pass else : try : _event = get_master_event ( opts , opts [ 'sock_dir' ] , listen = False ) tag = tagify ( tag_suffix , prefix ) _event . fire_event ( tag_data , tag = tag ) except Exception as exc : log . warning ( 'Failed to fire args event %s with data %s: %s' , tag , tag_data , exc )
fire an event containing the arguments passed to an orchestration job .