def notify_about_aggregate_update(context, event_suffix, aggregate_payload):
 aggregate_identifier = aggregate_payload.get('aggregate_id', None)
 if (not aggregate_identifier):
  aggregate_identifier = aggregate_payload.get('name', None)
  if (not aggregate_identifier):
   LOG.debug('No aggregate id or name specified for this notification and it will be ignored')
   return
 notifier = rpc.get_notifier(service='aggregate', host=aggregate_identifier)
 notifier.info(context, ('aggregate.%s' % event_suffix), aggregate_payload)

def notify_about_aggregate_update ( context , event_suffix , aggregate_payload ) : aggregate_identifier = aggregate_payload . get ( 'aggregate_id' , None ) if ( not aggregate_identifier ) : aggregate_identifier = aggregate_payload . get ( 'name' , None ) if ( not aggregate_identifier ) : LOG . debug ( 'No aggregate id or name specified for this notification and it will be ignored' ) return notifier = rpc . get_notifier ( service = 'aggregate' , host = aggregate_identifier ) notifier . info ( context , ( 'aggregate.%s' % event_suffix ) , aggregate_payload )
send a notification about aggregate update .