gwcelery.tasks.alerts module¶
- (task)gwcelery.tasks.alerts._add_external_coinc_to_alert(alert_dict, superevent)[source]¶
Proxy that evaluates object once.
Proxy
will evaluate the object each time, while the promise will only evaluate it once.
- (task)gwcelery.tasks.alerts._upload_notice(payload, brokerhost, superevent_id)[source]¶
Upload serialized alert notice to GraceDB
- (task)gwcelery.tasks.alerts._send(alert_dict, skymap, brokerhost)[source]¶
Write the alert to the Kafka topic
- (task)gwcelery.tasks.alerts.send(skymap_and_classification, superevent, alert_type, raven_coinc=False)[source]¶
Send an public alert to all currently connected kafka brokers.
- Parameters:
skymap_and_classification (tuple, None) – The filecontents of the skymap followed by a collection of JSON strings. The former generated by
gwcelery.tasks.gracedb.download()
, the latter generated bygwcelery.tasks.em_bright.classifier()
andgwcelery.tasks.p_astro.compute_p_astro()
or content ofp_astro.json
uploaded by gstlal respectively. Can also be None.superevent (dict) – The superevent dictionary, typically obtained from an IGWN Alert or from querying GraceDB.
alert_type ({'earlywarning', 'preliminary', 'initial', 'update'}) – The alert type.
raven_coinc (bool) – Is there a coincident external event processed by RAVEN?
- (task)gwcelery.tasks.alerts._create_skymap_classification_tuple(skymap, classification)[source]¶
Proxy that evaluates object once.
Proxy
will evaluate the object each time, while the promise will only evaluate it once.
- (task)gwcelery.tasks.alerts.download_skymap_and_send_alert(classification, superevent, alert_type, skymap_filename=None, raven_coinc=False)[source]¶
Wrapper for send function when caller has not already downloaded the skymap.
- Parameters:
classification (tuple, None) – A collection of JSON strings, generated by
gwcelery.tasks.em_bright.classifier()
andgwcelery.tasks.p_astro.compute_p_astro()
or content ofp_astro.json
uploaded by gstlal respectively; or Nonesuperevent (dict) – The superevent dictionary, typically obtained from an IGWN Alert or from querying GraceDB.
alert_type ({'earlywarning', 'preliminary', 'initial', 'update'}) – The alert type.
skymap_filename (string) – The skymap filename.
raven_coinc (bool) – Is there a coincident external event processed by RAVEN?