API Reference¶
Celery application initialization.
- gwcelery.app = <Celery gwcelery>¶
Celery application object.
- gwcelery.conf module
worker_proc_alive_timeoutworker_log_formatcondor_accounting_groupexpose_to_publicigwn_alert_serverigwn_alert_noauthigwn_alert_groupgracedb_hostgwskynet_upper_far_thresholdgwskynet_snr_thresholdgwskynet_network_snr_thresholdcreate_mattermost_channelkafka_consumer_configviews_manual_preferred_event_log_messagevoevent_broadcaster_addressvoevent_broadcaster_whitelistvoevent_receiver_addressemail_hostsuperevent_d_t_startsuperevent_d_t_endsuperevent_query_d_t_startsuperevent_query_d_t_endsuperevent_default_d_t_startsuperevent_default_d_t_endsuperevent_far_thresholdsuperevent_candidate_preferencesignificant_alert_far_thresholdsignificant_alert_trials_factorpreliminary_alert_trials_factorpreliminary_alert_far_thresholdsnews_gw_far_thresholdsog_paper_far_thresholdsuperevent_clean_up_timeoutpe_timeoutrapidpe_timeoutcheck_vector_prepostuses_gatedhoftllhoft_globllhoft_channelsidq_ok_channelsidq_channelsidq_fap_threshidq_vetolow_latency_frame_typeshigh_latency_frame_typesstrain_channel_namesstate_vector_channel_namesdetchar_bit_definitionsomegascan_durationspe_results_pathpe_results_urlraven_coincidence_windowsraven_ext_ratesraven_targeted_far_thresholdsexternal_search_preferencemock_events_simulate_multiple_uploadsonly_alert_for_mdcjoint_mdc_freqjoint_O3_replay_freqcondor_retry_kwargsrapidpe_condor_retry_kwargsrapidpe_settings- gwcelery.conf.minikube module
- gwcelery.conf.dev module
- gwcelery.conf.playground module
- gwcelery.conf.production module
condor_accounting_groupexpose_to_publicigwn_alert_groupgracedb_hostcreate_mattermost_channelkafka_alert_configkafka_consumer_configvoevent_broadcaster_addressvoevent_broadcaster_whitelistllhoft_globlow_latency_frame_typeshigh_latency_frame_typesidq_channelsstrain_channel_namessentry_environmentonly_alert_for_mdccondor_retry_kwargsrapidpe_settings
- gwcelery.conf.test module
- gwcelery.email module
- gwcelery.igwn_alert 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
COMBINED_SKYMAP_FILENAME_MULTIORDERCOMBINED_SKYMAP_FILENAME_PNGFERMI_OFFICIAL_SKYMAP_FILENAMEcreate_combined_skymapget_skymap_filenameis_skymap_moc()_download_skymapscombine_skymaps_moc_moc()combine_skymaps_moc_flat()combine_skymapsexternal_trigger_heasarcget_external_skymapread_upload_skymap_from_base64get_upload_external_skymapfrom_cone()fermi_error_model()create_external_skymap()write_to_fits()create_upload_external_skymapplot_overlap_integral
- gwcelery.tasks.external_triggers module
- gwcelery.tasks.first2years module
- gwcelery.tasks.first2years_external module
- gwcelery.tasks.gcn module
- gwcelery.tasks.gracedb module
RetryableHTTPErrorcatch_retryable_http_errors()task()add_pipeline_preferred_eventcreate_eventcreate_labelcreate_label_with_logremove_labelcreate_signoffcreate_tagcreate_voeventdownloadexposeget_eventsget_eventget_groupget_searchget_labelsget_logget_supereventreplace_eventuploadget_supereventsremove_pipeline_preferred_eventupdate_supereventcreate_supereventadd_event_to_supereventget_superevent_file_listget_latest_file
- gwcelery.tasks.gwskynet module
- gwcelery.tasks.igwn_alert module
- gwcelery.tasks.inference module
- gwcelery.tasks.legacy_gracedb module
- gwcelery.tasks.notice_text module
- gwcelery.tasks.orchestrator module
- Preliminary Alerts
- Initial and Update Alerts
- Retraction Alerts
- Tasks
handle_supereventhandle_cbc_eventhandle_burst_eventhandle_posterior_samples_create_mattermost_channel_set_pipeline_preferred_events_update_if_dqok_create_voevent_create_label_and_return_filename_leave_log_message_and_return_event_dict_update_superevent_and_return_event_dict_proceed_if_not_blocked_by_revise_and_send_second_less_significant_alert_annotate_fits_and_return_input_unpack_args_and_send_earlywarning_preliminary_alertearlywarning_preliminary_alert_get_pe_far_and_eventparameter_estimationearlywarning_preliminary_initial_update_alert_update_rapidpe_pastro_update_rapidpe_pastro_shouldnt_run_upload_rapidpe_pastro_json_check_pastro_and_send_alertinitial_alertupdate_alertretraction_alert
- gwcelery.tasks.p_astro module
- gwcelery.tasks.raven module
- gwcelery.tasks.rrt_utils module
- gwcelery.tasks.skymaps module
- gwcelery.tasks.superevents module
- Selection of the preferred event
- Tasks
REQUIRED_LABELS_BY_GROUP_SEARCHFROZEN_LABELSIGNIFICANT_LABELEARLY_WARNING_LABELEARLY_WARNING_SEARCH_NAMEREADY_LABELVT_SEARCH_NAMEhandleprocessget_category()get_ts()get_snr()get_instruments()get_instruments_in_ranking_statistic()select_pipeline_preferred_eventselect_preferred_eventis_complete()should_publish()keyfunc()
- gwcelery.tools module
- gwcelery.tools.condor module
- gwcelery.tools.flask module
- gwcelery.tools.nagios module
NagiosPluginStatusNagiosCriticalErrorget_active_queues()get_active_igwn_alert_topics()get_expected_queues()get_expected_igwn_alert_topics()get_active_voevent_peers()get_expected_kafka_bootstep_urls()get_active_kafka_bootstep_urls()get_undelivered_message_urls()get_active_kafka_consumer_bootstep_names()get_expected_kafka_consumer_bootstep_names()get_celery_queue_length()get_recent_mdc_superevents()get_distr_delay_latest_llhoft()check_status()
- gwcelery.util module
- gwcelery.voevent module