gwcelery.tasks.orchestrator module¶
This module implements the alert orchestrator, which responsible for the vetting and annotation workflow to produce preliminary, initial, and update alerts for gravitational-wave event candidates.
The orchestrator consists of two LVAlert message handlers:
handle_superevent()
is called for each superevent. It waits for a short duration oforchestrator_timeout
seconds for the selection of the superevent by thesuperevent manager
to stabilize, then performs data quality checks. If the data quality checks pass, then it callspreliminary_alert()
to copy annotations from the preferred event and send the preliminary GCN notice.handle_cbc_event()
is called for each CBC event. It performs some CBC-specific annotations that depend closely on the CBC matched-filter parameters estimates and that might influence selection of the preferred event: rapid sky localization with BAYESTAR and rapid source classification.Note that there is no equivalent of this task for burst events because both burst searches (cWB, LIB) have integrated source localization and have no other annotations.
Preliminary Alerts¶
The flow chart below illustrates the operation of these two tasks.
Initial and Update Alerts¶
The initial_alert()
and
update_alert()
tasks create Initial and Update alerts
respectively. At the moment, there is no handler or user interface to trigger
these tasks, and they must be invoked manually (see
Command-Line Tools). A flow chart for the initial alerts is
shown below; the flow chart for update alerts is the same.
Retraction Alerts¶
Likewise, the retraction_alert()
task creates Retraction
alerts, and at the moment must be invoked manually. A flow chart is shown below.
Tasks¶
Tasks that comprise the alert orchestrator, which responsible for the vetting and annotation workflow to produce preliminary, initial, and update alerts for gravitational-wave event candidates.
-
(task)
gwcelery.tasks.orchestrator.
handle_superevent
(alert)[source]¶ Schedule annotations for new superevents.
After waiting for a time specified by the
orchestrator_timeout
configuration variable for the choice of preferred event to settle down, this task peforms data quality checks withgwcelery.tasks.detchar.check_vectors()
and callspreliminary_alert()
to send a preliminary GCN notice.
-
(task)
gwcelery.tasks.orchestrator.
handle_cbc_event
(alert)[source]¶ Peform annotations for CBC events that depend on pipeline-specific matched-filter parameter estimates.
Notes
This LVAlert message handler is triggered by updates that include the files
psd.xml.gz
andranking_data.xml.gz
. The table below lists which files are created as a result, and which tasks generate them.File
Task
bayestar.fits
em_bright.json
gwcelery.tasks.em_bright.classifier()
p_astro.json
-
(task)
gwcelery.tasks.orchestrator.
preliminary_alert
(event, superevent_id)[source]¶ Produce a preliminary alert by copying any sky maps.
This consists of the following steps:
Copy any sky maps and source classification from the preferred event to the superevent.
Create standard annotations for sky maps including all-sky plots by calling
gwcelery.tasks.skymaps.annotate_fits()
.Create a preliminary VOEvent.
Send the VOEvent to GCN.
Apply the GCN_PRELIM_SENT label to the superevent.
Create and upload a GCN Circular draft.
-
(task)
gwcelery.tasks.orchestrator.
parameter_estimation
(event, superevent_id)[source]¶ Tasks for Parameter Estimation Followup with LALInference
This consists of the following steps:
Upload an ini file which is suitable for the target event.
Start Parameter Estimation if FAR is smaller than the PE threshold.
-
(task)
gwcelery.tasks.orchestrator.
initial_or_update_alert
(superevent_id, alert_type, skymap_filename=None, em_bright_filename=None, p_astro_filename=None)[source]¶ Create and send initial or update GCN notice.
- Parameters
superevent_id (str) – The superevent ID.
alert_type ({'initial', 'update'}) – The alert type.
skymap_filename (str, optional) – The sky map to send. If None, then most recent public sky map is used.
em_bright_filename (str, optional) – The source classification file to use. If None, then most recent one is used.
p_astro_filename (str, optional) – The p_astro file to use. If None, then most recent one is used.
-
(task)
gwcelery.tasks.orchestrator.
initial_alert
(superevent_id, skymap_filename=None, em_bright_filename=None, p_astro_filename=None)[source]¶ Produce an initial alert.
This does nothing more than call
initial_or_update_alert()
withalert_type='initial'
.- Parameters
superevent_id (str) – The superevent ID.
skymap_filename (str, optional) – The sky map to send. If None, then most recent public sky map is used.
em_bright_filename (str, optional) – The source classification file to use. If None, then most recent one is used.
p_astro_filename (str, optional) – The p_astro file to use. If None, then most recent one is used.
-
(task)
gwcelery.tasks.orchestrator.
update_alert
(superevent_id, skymap_filename=None, em_bright_filename=None, p_astro_filename=None)[source]¶ Produce an update alert.
This does nothing more than call
initial_or_update_alert()
withalert_type='update'
.- Parameters
superevent_id (str) – The superevent ID.
skymap_filename (str, optional) – The sky map to send. If None, then most recent public sky map is used.
em_bright_filename (str, optional) – The source classification file to use. If None, then most recent one is used.
p_astro_filename (str, optional) – The p_astro file to use. If None, then most recent one is used.