gwcelery.tasks.lvalert module¶
LVAlert client.
-
gwcelery.tasks.lvalert.
handler
= {'burst_cwb': [<@task: gwcelery.tasks.superevents.handle of gwcelery>], 'burst_olib': [<@task: gwcelery.tasks.superevents.handle of gwcelery>], 'cbc_gstlal': [<@task: gwcelery.tasks.orchestrator.handle_cbc_event of gwcelery>, <@task: gwcelery.tasks.superevents.handle of gwcelery>], 'cbc_mbtaonline': [<@task: gwcelery.tasks.orchestrator.handle_cbc_event of gwcelery>, <@task: gwcelery.tasks.superevents.handle of gwcelery>], 'cbc_pycbc': [<@task: gwcelery.tasks.orchestrator.handle_cbc_event of gwcelery>, <@task: gwcelery.tasks.superevents.handle of gwcelery>], 'cbc_spiir': [<@task: gwcelery.tasks.orchestrator.handle_cbc_event of gwcelery>, <@task: gwcelery.tasks.superevents.handle of gwcelery>], 'external_fermi': [<@task: gwcelery.tasks.external_triggers.handle_grb_lvalert of gwcelery>], 'external_fermi_grb': [<@task: gwcelery.tasks.external_triggers.handle_grb_lvalert of gwcelery>], 'external_grb': [<@task: gwcelery.tasks.external_triggers.handle_grb_lvalert of gwcelery>], 'external_snews': [<@task: gwcelery.tasks.external_triggers.handle_snews_lvalert of gwcelery>], 'external_snews_supernova': [<@task: gwcelery.tasks.external_triggers.handle_snews_lvalert of gwcelery>], 'external_swift': [<@task: gwcelery.tasks.external_triggers.handle_grb_lvalert of gwcelery>], 'mdc_superevent': [<@task: gwcelery.tasks.external_triggers.handle_grb_lvalert of gwcelery>, <@task: gwcelery.tasks.external_triggers.handle_snews_lvalert of gwcelery>, <@task: gwcelery.tasks.orchestrator.handle_superevent of gwcelery>, <@task: gwcelery.tasks.p_astro.handle of gwcelery>], 'superevent': [<@task: gwcelery.tasks.external_triggers.handle_grb_lvalert of gwcelery>, <@task: gwcelery.tasks.external_triggers.handle_snews_lvalert of gwcelery>, <@task: gwcelery.tasks.external_triggers.handle_emcoinc_lvalert of gwcelery>, <@task: gwcelery.tasks.orchestrator.handle_superevent of gwcelery>, <@task: gwcelery.tasks.p_astro.handle of gwcelery>], 'test_gstlal': [<@task: gwcelery.tasks.superevents.handle of gwcelery>], 'test_mbtaonline': [<@task: gwcelery.tasks.superevents.handle of gwcelery>], 'test_pycbc': [<@task: gwcelery.tasks.superevents.handle of gwcelery>], 'test_superevent': [<@task: gwcelery.tasks.external_triggers.handle_grb_lvalert of gwcelery>, <@task: gwcelery.tasks.external_triggers.handle_snews_lvalert of gwcelery>]}¶ Function decorator to register a handler callback for specified LVAlert message types. The decorated function is turned into a Celery task, which will be automatically called whenever a matching LVAlert message is received.
Parameters: - *keys – List of LVAlert message types to accept
- **kwargs – Additional keyword arguments for
celery.Celery.task()
.
Examples
Declare a new handler like this:
@lvalert.handler('cbc_gstlal', 'cbc_spiir', 'cbc_pycbc', 'cbc_mbtaonline') def handle_cbc(alert_content): # do work here...
-
(task)
gwcelery.tasks.lvalert.
listen
[source]¶ Listen for LVAlert messages forever. LVAlert messages are dispatched asynchronously to tasks that have been registered with
gwcelery.tasks.lvalert.handler()
.