API Reference¶
Celery application initialization.
- gwcelery.app = <Celery gwcelery>¶
Celery application object.
- gwcelery.conf module
worker_proc_alive_timeout
worker_log_format
condor_accounting_group
expose_to_public
igwn_alert_server
igwn_alert_noauth
igwn_alert_group
gracedb_host
gwskynet_upper_far_threshold
gwskynet_snr_threshold
gwskynet_network_snr_threshold
create_mattermost_channel
kafka_consumer_config
views_manual_preferred_event_log_message
voevent_broadcaster_address
voevent_broadcaster_whitelist
voevent_receiver_address
email_host
superevent_d_t_start
superevent_d_t_end
superevent_query_d_t_start
superevent_query_d_t_end
superevent_default_d_t_start
superevent_default_d_t_end
superevent_far_threshold
superevent_candidate_preference
significant_alert_far_threshold
significant_alert_trials_factor
preliminary_alert_trials_factor
preliminary_alert_far_threshold
snews_gw_far_threshold
sog_paper_far_threshold
superevent_clean_up_timeout
pe_timeout
rapidpe_timeout
check_vector_prepost
uses_gatedhoft
llhoft_glob
llhoft_channels
idq_ok_channels
idq_channels
idq_fap_thresh
idq_veto
low_latency_frame_types
high_latency_frame_types
strain_channel_names
state_vector_channel_names
detchar_bit_definitions
omegascan_durations
pe_results_path
pe_results_url
raven_coincidence_windows
raven_ext_rates
raven_targeted_far_thresholds
external_search_preference
mock_events_simulate_multiple_uploads
only_alert_for_mdc
joint_mdc_freq
joint_O3_replay_freq
condor_retry_kwargs
rapidpe_condor_retry_kwargs
rapidpe_settings
- gwcelery.conf.minikube module
- gwcelery.conf.dev module
- gwcelery.conf.playground module
- gwcelery.conf.production module
condor_accounting_group
expose_to_public
igwn_alert_group
gracedb_host
create_mattermost_channel
kafka_alert_config
kafka_consumer_config
voevent_broadcaster_address
voevent_broadcaster_whitelist
llhoft_glob
low_latency_frame_types
high_latency_frame_types
idq_channels
strain_channel_names
sentry_environment
only_alert_for_mdc
condor_retry_kwargs
rapidpe_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_MULTIORDER
COMBINED_SKYMAP_FILENAME_PNG
FERMI_OFFICIAL_SKYMAP_FILENAME
create_combined_skymap
get_skymap_filename
is_skymap_moc()
_download_skymaps
combine_skymaps_moc_moc()
combine_skymaps_moc_flat()
combine_skymaps
external_trigger_heasarc
get_external_skymap
read_upload_skymap_from_base64
get_upload_external_skymap
from_cone()
fermi_error_model()
create_external_skymap()
write_to_fits()
create_upload_external_skymap
plot_overlap_integral
- gwcelery.tasks.external_triggers module
- gwcelery.tasks.first2years module
- gwcelery.tasks.first2years_external module
- gwcelery.tasks.gcn module
- gwcelery.tasks.gracedb module
RetryableHTTPError
catch_retryable_http_errors()
task()
add_pipeline_preferred_event
create_event
create_label
remove_label
create_signoff
create_tag
create_voevent
download
expose
get_events
get_event
get_group
get_search
get_labels
get_log
get_superevent
replace_event
upload
get_superevents
remove_pipeline_preferred_event
update_superevent
create_superevent
add_event_to_superevent
get_superevent_file_list
get_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_superevent
handle_cbc_event
handle_burst_event
handle_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_alert
earlywarning_preliminary_alert
_get_pe_far_and_event
parameter_estimation
earlywarning_preliminary_initial_update_alert
_update_rapidpe_pastro
_update_rapidpe_pastro_shouldnt_run
_upload_rapidpe_pastro_json
_check_pastro_and_send_alert
initial_alert
update_alert
retraction_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_SEARCH
FROZEN_LABEL
SIGNIFICANT_LABEL
EARLY_WARNING_LABEL
EARLY_WARNING_SEARCH_NAME
READY_LABEL
VT_SEARCH_NAME
handle
process
get_category()
get_ts()
get_snr()
get_instruments()
get_instruments_in_ranking_statistic()
select_pipeline_preferred_event
select_preferred_event
is_complete()
should_publish()
keyfunc()
- gwcelery.tools module
- gwcelery.tools.condor module
- gwcelery.tools.flask module
- gwcelery.tools.nagios module
NagiosPluginStatus
NagiosCriticalError
get_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