Index

_

_add_external_coinc_to_alert() (in module gwcelery.tasks.alerts) _annotate_fits_and_return_input() (in module gwcelery.tasks.orchestrator) _check_pastro_and_send_alert() (in module gwcelery.tasks.orchestrator) _clean_up_bilby() (in module gwcelery.tasks.inference) _condor_no_submit() (in module gwcelery.tasks.inference) _create_label_and_return_filename() (in module gwcelery.tasks.orchestrator) _create_mattermost_channel() (in module gwcelery.tasks.orchestrator) _create_replace_external_event_and_skymap() (in module gwcelery.tasks.external_triggers) _create_skymap_classification_tuple() (in module gwcelery.tasks.alerts) _download_and_return_file_name() (in module gwcelery.tasks.gwskynet) _download_skymaps() (in module gwcelery.tasks.external_skymaps) _get_pe_far_and_event() (in module gwcelery.tasks.orchestrator) _launch_external_detchar() (in module gwcelery.tasks.external_triggers) _leave_log_message_and_return_event_dict() (in module gwcelery.tasks.orchestrator) _log_event_and_return_query() (in module gwcelery.tasks.first2years) _proceed_if_not_blocked_by() (in module gwcelery.tasks.orchestrator)

_revise_and_send_second_less_significant_alert() (in module gwcelery.tasks.orchestrator) _send() (in module gwcelery.tasks.alerts) _send_with_combined() (in module gwcelery.tasks.alerts) _set_pipeline_preferred_events() (in module gwcelery.tasks.orchestrator) _setup_dag_for_bilby() (in module gwcelery.tasks.inference) _setup_dag_for_lalinference() (in module gwcelery.tasks.inference) _setup_dag_for_rapidpe() (in module gwcelery.tasks.inference) _unpack_args_and_send_earlywarning_preliminary_alert() (in module gwcelery.tasks.orchestrator) _unpack_gwskynet_annotation_and_upload() (in module gwcelery.tasks.gwskynet) _update_if_dqok() (in module gwcelery.tasks.orchestrator) _update_rapidpe_pastro() (in module gwcelery.tasks.orchestrator) _update_rapidpe_pastro_shouldnt_run() (in module gwcelery.tasks.orchestrator) _update_superevent_and_return_event_dict() (in module gwcelery.tasks.orchestrator) _upload_notice() (in module gwcelery.tasks.alerts) _upload_rapidpe_pastro_json() (in module gwcelery.tasks.orchestrator) _vet_event() (in module gwcelery.tasks.first2years)

A

add_event_to_superevent() (in module gwcelery.tasks.gracedb) add_pipeline_preferred_event() (in module gwcelery.tasks.gracedb) annotate_fits() (in module gwcelery.tasks.skymaps)

annotate_fits_tuple() (in module gwcelery.tasks.skymaps) annotate_fits_volume() (in module gwcelery.tasks.skymaps) app (in module gwcelery)

C

calculate_coincidence_far() (in module gwcelery.tasks.raven) catch_retryable_http_errors() (in module gwcelery.tasks.gracedb) CeleryDaemonFlaskGroup (class in gwcelery.tools.flask) check_high_profile() (in module gwcelery.tasks.rrt_utils) check_idq() (in module gwcelery.tasks.detchar) check_output() (in module gwcelery.tasks.condor) check_status() (in module gwcelery.tools.nagios) check_vector() (in module gwcelery.tasks.detchar) check_vector_prepost (in module gwcelery.conf) check_vectors() (in module gwcelery.tasks.detchar) circular_timeout (in module gwcelery.conf) closing_figures() (in module gwcelery.util) coincidence_search() (in module gwcelery.tasks.raven) combine_skymaps() (in module gwcelery.tasks.external_skymaps) combine_skymaps_moc_flat() (in module gwcelery.tasks.external_skymaps) combine_skymaps_moc_moc() (in module gwcelery.tasks.external_skymaps) COMBINED_SKYMAP_FILENAME_MULTIORDER (in module gwcelery.tasks.external_skymaps) COMBINED_SKYMAP_FILENAME_PNG (in module gwcelery.tasks.external_skymaps) compute_p_astro() (in module gwcelery.tasks.p_astro) condor_accounting_group (in module gwcelery.conf) (in module gwcelery.conf.production)

condor_retry_kwargs (in module gwcelery.conf) (in module gwcelery.conf.production) configure() (in module gwcelery.sentry) create_cache() (in module gwcelery.tasks.detchar) create_combined_skymap() (in module gwcelery.tasks.external_skymaps) create_emcoinc_circular() (in module gwcelery.tasks.circulars) create_event() (in module gwcelery.tasks.gracedb) create_external_skymap() (in module gwcelery.tasks.external_skymaps) create_initial_circular() (in module gwcelery.tasks.circulars) create_label() (in module gwcelery.tasks.gracedb) create_label_with_log() (in module gwcelery.tasks.gracedb) create_mattermost_channel (in module gwcelery.conf) (in module gwcelery.conf.production) create_medium_latency_circular() (in module gwcelery.tasks.circulars) create_offset_external_skymap() (in module gwcelery.tasks.external_skymaps) create_retraction_circular() (in module gwcelery.tasks.circulars) create_signoff() (in module gwcelery.tasks.gracedb) create_tag() (in module gwcelery.tasks.gracedb) create_update_circular() (in module gwcelery.tasks.circulars) create_upload_external_event() (in module gwcelery.tasks.first2years_external) create_upload_external_skymap() (in module gwcelery.tasks.external_skymaps) CRITICAL (gwcelery.tools.nagios.NagiosPluginStatus attribute)

D

dag_finished() (in module gwcelery.tasks.inference) dag_prepare_task() (in module gwcelery.tasks.inference) detchar_bit_definitions (in module gwcelery.conf) dispatch() (gwcelery.tasks.core.DispatchHandler method)

DispatchHandler (class in gwcelery.tasks.core) download() (in module gwcelery.tasks.gracedb) download_skymap_and_send_alert() (in module gwcelery.tasks.alerts) dqr_json() (in module gwcelery.tasks.detchar) DSN (in module gwcelery.sentry)

E

EARLY_WARNING_LABEL (in module gwcelery.tasks.superevents) EARLY_WARNING_SEARCH_NAME (in module gwcelery.tasks.superevents) earlywarning_preliminary_alert() (in module gwcelery.tasks.orchestrator) earlywarning_preliminary_initial_update_alert() (in module gwcelery.tasks.orchestrator) em_bright_posterior_samples() (in module gwcelery.tasks.em_bright)

expose() (in module gwcelery.tasks.gracedb) expose_to_public (in module gwcelery.conf) (in module gwcelery.conf.minikube) (in module gwcelery.conf.production) external_search_preference (in module gwcelery.conf) external_trigger_heasarc() (in module gwcelery.tasks.external_skymaps)

F

fermi_error_model() (in module gwcelery.tasks.external_skymaps) FERMI_GRB_CLASS_VALUE (in module gwcelery.tasks.external_triggers) FERMI_OFFICIAL_SKYMAP_FILENAME (in module gwcelery.tasks.external_skymaps)

fits_header() (in module gwcelery.tasks.skymaps) flatten() (in module gwcelery.tasks.skymaps) from_cone() (in module gwcelery.tasks.external_skymaps) FROZEN_LABEL (in module gwcelery.tasks.superevents)

G

generate_dag_and_submit_files() (in module gwcelery.tools.condor) generate_table() (in module gwcelery.tasks.detchar) get_active_igwn_alert_topics() (in module gwcelery.tools.nagios) get_active_kafka_bootstep_urls() (in module gwcelery.tools.nagios) get_active_kafka_consumer_bootstep_names() (in module gwcelery.tools.nagios) get_active_queues() (in module gwcelery.tools.nagios) get_cbc_event_snr() (in module gwcelery.tasks.gwskynet) get_celery_queue_length() (in module gwcelery.tools.nagios) get_constraints() (in module gwcelery.tools.condor) get_distr_delay_latest_llhoft() (in module gwcelery.tools.nagios) get_event() (in module gwcelery.tasks.gracedb) get_events() (in module gwcelery.tasks.gracedb) get_expected_igwn_alert_topics() (in module gwcelery.tools.nagios) get_expected_kafka_bootstep_urls() (in module gwcelery.tools.nagios) get_expected_kafka_consumer_bootstep_names() (in module gwcelery.tools.nagios) get_expected_queues() (in module gwcelery.tools.nagios) get_external_skymap() (in module gwcelery.tasks.external_skymaps) get_first() (in module gwcelery.tasks.core) get_group() (in module gwcelery.tasks.gracedb) get_instruments() (in module gwcelery.tasks.superevents) get_instruments_in_ranking_statistic() (in module gwcelery.tasks.superevents) get_labels() (in module gwcelery.tasks.gracedb) get_last() (in module gwcelery.tasks.core) get_latest_file() (in module gwcelery.tasks.gracedb) get_log() (in module gwcelery.tasks.gracedb) get_recent_mdc_superevents() (in module gwcelery.tools.nagios) get_search() (in module gwcelery.tasks.gracedb) get_skymap_filename() (in module gwcelery.tasks.external_skymaps) get_snr() (in module gwcelery.tasks.superevents) get_superevent() (in module gwcelery.tasks.gracedb) get_superevent_file_list() (in module gwcelery.tasks.gracedb) get_superevents() (in module gwcelery.tasks.gracedb) get_undelivered_message_urls() (in module gwcelery.tools.nagios) get_upload_external_skymap() (in module gwcelery.tasks.external_skymaps) gracedb_host (in module gwcelery.conf) (in module gwcelery.conf.dev) (in module gwcelery.conf.minikube) (in module gwcelery.conf.playground) (in module gwcelery.conf.production) (in module gwcelery.conf.test) gwcelery module gwcelery.conf module gwcelery.conf.dev module gwcelery.conf.minikube module gwcelery.conf.playground module gwcelery.conf.production module gwcelery.conf.test module gwcelery.igwn_alert module gwcelery.igwn_alert.bootsteps module gwcelery.igwn_alert.signals module

gwcelery.sentry module gwcelery.tasks module gwcelery.tasks.alerts module gwcelery.tasks.bayestar module gwcelery.tasks.circulars module gwcelery.tasks.condor module gwcelery.tasks.core module gwcelery.tasks.detchar module gwcelery.tasks.em_bright module gwcelery.tasks.external_skymaps module gwcelery.tasks.external_triggers module gwcelery.tasks.first2years module gwcelery.tasks.first2years_external module gwcelery.tasks.gracedb module gwcelery.tasks.gwskynet module gwcelery.tasks.igwn_alert module gwcelery.tasks.inference module gwcelery.tasks.orchestrator module gwcelery.tasks.p_astro module gwcelery.tasks.raven module gwcelery.tasks.rrt_utils module gwcelery.tasks.skymaps module gwcelery.tasks.superevents module gwcelery.tools module gwcelery.tools.condor module gwcelery.tools.flask module gwcelery.tools.nagios module gwcelery.util module gwskynet_annotation() (in module gwcelery.tasks.gwskynet) GWSkyNet_model() (in module gwcelery.tasks.gwskynet) gwskynet_network_snr_threshold (in module gwcelery.conf) gwskynet_snr_threshold (in module gwcelery.conf) gwskynet_upper_far_threshold (in module gwcelery.conf)

H

handle() (in module gwcelery.tasks.em_bright) (in module gwcelery.tasks.p_astro) (in module gwcelery.tasks.superevents) handle_aframe_event() (in module gwcelery.tasks.orchestrator) handle_burst_event() (in module gwcelery.tasks.orchestrator) handle_cbc_superevent() (in module gwcelery.tasks.gwskynet) handle_frb_igwn_alert() (in module gwcelery.tasks.external_triggers) handle_grb_gcn() (in module gwcelery.tasks.external_triggers) handle_grb_igwn_alert() (in module gwcelery.tasks.external_triggers) handle_hen_igwn_alert() (in module gwcelery.tasks.external_triggers) handle_kafka_alert() (in module gwcelery.tasks.external_triggers)

handle_match_filter_cbc_event() (in module gwcelery.tasks.orchestrator) handle_posterior_samples() (in module gwcelery.tasks.orchestrator) handle_snews_gcn() (in module gwcelery.tasks.external_triggers) handle_snews_igwn_alert() (in module gwcelery.tasks.external_triggers) handle_superevent() (in module gwcelery.tasks.orchestrator) handle_superevent_igwn_alert() (in module gwcelery.tasks.external_triggers) handler (in module gwcelery.tasks.alerts) (in module gwcelery.tasks.igwn_alert) handling_system_exit() (in module gwcelery.util) high_latency_frame_types (in module gwcelery.conf) (in module gwcelery.conf.production) (in module gwcelery.conf.test)

I

identity() (in module gwcelery.tasks.core) idq_channels (in module gwcelery.conf) (in module gwcelery.conf.dev) (in module gwcelery.conf.minikube) (in module gwcelery.conf.production) idq_fap_thresh (in module gwcelery.conf) idq_ok_channels (in module gwcelery.conf) (in module gwcelery.conf.dev) (in module gwcelery.conf.minikube) idq_veto (in module gwcelery.conf) ifo_from_channel() (in module gwcelery.tasks.detchar) igwn_alert_group (in module gwcelery.conf) (in module gwcelery.conf.dev) (in module gwcelery.conf.minikube) (in module gwcelery.conf.playground) (in module gwcelery.conf.production) (in module gwcelery.conf.test)

igwn_alert_noauth (in module gwcelery.conf) (in module gwcelery.conf.minikube) igwn_alert_received (in module gwcelery.igwn_alert.signals) igwn_alert_server (in module gwcelery.conf) (in module gwcelery.conf.minikube) info() (gwcelery.igwn_alert.bootsteps.Receiver method) initial_alert() (in module gwcelery.tasks.orchestrator) install() (in module gwcelery.igwn_alert) is_3d_fits_file() (in module gwcelery.tasks.skymaps) is_complete() (in module gwcelery.tasks.superevents) is_skymap_moc() (in module gwcelery.tasks.external_skymaps) IVORN_PIPELINE_DICT (in module gwcelery.tasks.first2years_external)

J

job_error_notification() (in module gwcelery.tasks.inference) JobAborted JobFailed

JobRunning joint_mdc_freq (in module gwcelery.conf) joint_O3_replay_freq (in module gwcelery.conf)

K

kafka_alert_config (in module gwcelery.conf.dev) (in module gwcelery.conf.minikube) (in module gwcelery.conf.playground) (in module gwcelery.conf.production) (in module gwcelery.conf.test)

kafka_consumer_config (in module gwcelery.conf) (in module gwcelery.conf.minikube) (in module gwcelery.conf.production) keyfunc() (in module gwcelery.tasks.raven) (in module gwcelery.tasks.superevents)

L

llhoft_channels (in module gwcelery.conf) (in module gwcelery.conf.dev) llhoft_glob (in module gwcelery.conf) (in module gwcelery.conf.dev) (in module gwcelery.conf.minikube) (in module gwcelery.conf.production) (in module gwcelery.conf.test)

localize() (in module gwcelery.tasks.bayestar) low_latency_frame_types (in module gwcelery.conf) (in module gwcelery.conf.dev) (in module gwcelery.conf.minikube) (in module gwcelery.conf.production) (in module gwcelery.conf.test)

M

make_context() (gwcelery.tools.flask.CeleryDaemonFlaskGroup method) make_omegascan() (in module gwcelery.tasks.detchar) maybe_detached() (in module gwcelery.tools.flask) mock_events_simulate_multiple_uploads (in module gwcelery.conf) (in module gwcelery.conf.dev) (in module gwcelery.conf.minikube) (in module gwcelery.conf.playground) (in module gwcelery.conf.test) module gwcelery gwcelery.conf gwcelery.conf.dev gwcelery.conf.minikube gwcelery.conf.playground gwcelery.conf.production gwcelery.conf.test gwcelery.igwn_alert gwcelery.igwn_alert.bootsteps gwcelery.igwn_alert.signals gwcelery.sentry gwcelery.tasks gwcelery.tasks.alerts gwcelery.tasks.bayestar gwcelery.tasks.circulars gwcelery.tasks.condor gwcelery.tasks.core gwcelery.tasks.detchar gwcelery.tasks.em_bright gwcelery.tasks.external_skymaps gwcelery.tasks.external_triggers gwcelery.tasks.first2years gwcelery.tasks.first2years_external gwcelery.tasks.gracedb gwcelery.tasks.gwskynet gwcelery.tasks.igwn_alert gwcelery.tasks.inference gwcelery.tasks.orchestrator gwcelery.tasks.p_astro gwcelery.tasks.raven gwcelery.tasks.rrt_utils gwcelery.tasks.skymaps gwcelery.tasks.superevents gwcelery.tools gwcelery.tools.condor gwcelery.tools.flask gwcelery.tools.nagios gwcelery.util

N

NagiosCriticalError NagiosPluginStatus (class in gwcelery.tools.nagios)

name (gwcelery.igwn_alert.bootsteps.Receiver attribute) NamedTemporaryFile() (in module gwcelery.util) NOTICE_TYPE_DICT (in module gwcelery.tasks.external_triggers)

O

OK (gwcelery.tools.nagios.NagiosPluginStatus attribute) omegascan() (in module gwcelery.tasks.detchar)

omegascan_durations (in module gwcelery.conf) only_alert_for_mdc (in module gwcelery.conf) (in module gwcelery.conf.production)

P

P_ASTRO_THRESH (in module gwcelery.tasks.external_triggers) parameter_estimation() (in module gwcelery.tasks.orchestrator) pe_results_path (in module gwcelery.conf) pe_results_url (in module gwcelery.conf) pe_timeout (in module gwcelery.conf) pick_coinc() (in module gwcelery.tasks.first2years) plot() (in module gwcelery.tasks.em_bright) (in module gwcelery.tasks.p_astro) plot_allsky() (in module gwcelery.tasks.skymaps) plot_coherence() (in module gwcelery.tasks.skymaps)

plot_overlap_integral() (in module gwcelery.tasks.external_skymaps) plot_volume() (in module gwcelery.tasks.skymaps) preferred_superevent() (in module gwcelery.tasks.raven) preliminary_alert_far_threshold (in module gwcelery.conf) preliminary_alert_trials_factor (in module gwcelery.conf) prepare_lalinference_ini() (in module gwcelery.tasks.inference) process() (in module gwcelery.tasks.superevents) process_args() (gwcelery.tasks.core.DispatchHandler method) PromiseProxy (class in gwcelery.util) Python Enhancement Proposals PEP 8

R

rapidpe_condor_retry_kwargs (in module gwcelery.conf) RAPIDPE_ENVIRONMENT (in module gwcelery.tasks.inference) RAPIDPE_GETENV (in module gwcelery.tasks.inference) rapidpe_settings (in module gwcelery.conf) (in module gwcelery.conf.dev) (in module gwcelery.conf.playground) (in module gwcelery.conf.production) rapidpe_timeout (in module gwcelery.conf) raven_coincidence_windows (in module gwcelery.conf) raven_ext_rates (in module gwcelery.conf) raven_pipeline() (in module gwcelery.tasks.raven) raven_targeted_far_thresholds (in module gwcelery.conf) read_binary() (in module gwcelery.util)

read_json() (in module gwcelery.util) read_text() (in module gwcelery.util) read_upload_skymap_from_base64() (in module gwcelery.tasks.external_skymaps) READY_LABEL (in module gwcelery.tasks.superevents) Receiver (class in gwcelery.igwn_alert.bootsteps) remove_label() (in module gwcelery.tasks.gracedb) remove_pipeline_preferred_event() (in module gwcelery.tasks.gracedb) replace_event() (in module gwcelery.tasks.gracedb) REQUIRED_LABELS_BY_GROUP_SEARCH (in module gwcelery.tasks.superevents) REQUIRED_LABELS_BY_TASK (in module gwcelery.tasks.external_triggers) retraction_alert() (in module gwcelery.tasks.orchestrator) RetryableHTTPError run_exec() (in module gwcelery.tools.condor) running() (in module gwcelery.tools.condor)

S

ScriptInfoWithCelery (class in gwcelery.tools.flask) search() (in module gwcelery.tasks.raven) select_pipeline_preferred_event() (in module gwcelery.tasks.superevents) select_preferred_event() (in module gwcelery.tasks.superevents) send() (in module gwcelery.tasks.alerts) sentry_environment (in module gwcelery.conf.dev) (in module gwcelery.conf.playground) (in module gwcelery.conf.production) (in module gwcelery.conf.test) setup_periodic_tasks() (in module gwcelery.tasks.first2years) should_publish() (in module gwcelery.tasks.superevents) significant_alert_far_threshold (in module gwcelery.conf) significant_alert_trials_factor (in module gwcelery.conf) SIGNIFICANT_LABEL (in module gwcelery.tasks.superevents) skymap_from_samples() (in module gwcelery.tasks.skymaps) snews_gw_far_threshold (in module gwcelery.conf)

sog_paper_far_threshold (in module gwcelery.conf) sog_paper_pipeline() (in module gwcelery.tasks.raven) source_properties() (in module gwcelery.tasks.em_bright) start() (gwcelery.igwn_alert.bootsteps.Receiver method) start_pe() (in module gwcelery.tasks.inference) state_vector_channel_names (in module gwcelery.conf) stop() (gwcelery.igwn_alert.bootsteps.Receiver method) strain_channel_names (in module gwcelery.conf) (in module gwcelery.conf.dev) (in module gwcelery.conf.minikube) (in module gwcelery.conf.production) (in module gwcelery.conf.test) submit() (in module gwcelery.tasks.condor) superevent_candidate_preference (in module gwcelery.conf) superevent_clean_up_timeout (in module gwcelery.conf) superevent_far_threshold (in module gwcelery.conf)

T

task() (in module gwcelery.tasks.gracedb)

trigger_raven_alert() (in module gwcelery.tasks.raven)

U

unflatten() (in module gwcelery.tasks.skymaps) UNKNOWN (gwcelery.tools.nagios.NagiosPluginStatus attribute) update_alert() (in module gwcelery.tasks.orchestrator) update_coinc_far() (in module gwcelery.tasks.raven) update_superevent() (in module gwcelery.tasks.gracedb)

upload() (in module gwcelery.tasks.gracedb) upload_event() (in module gwcelery.tasks.first2years) upload_external_event() (in module gwcelery.tasks.first2years_external) upload_snews_event() (in module gwcelery.tasks.first2years_external) uses_gatedhoft (in module gwcelery.conf)

V

views_manual_preferred_event_log_message (in module gwcelery.conf)

VT_SEARCH_NAME (in module gwcelery.tasks.superevents)

W

WARNING (gwcelery.tools.nagios.NagiosPluginStatus attribute) worker_log_format (in module gwcelery.conf)

worker_proc_alive_timeout (in module gwcelery.conf) write_to_fits() (in module gwcelery.tasks.external_skymaps)

Z

ZeroLengthResponse