gwcelery.tasks.gracedb module¶
Communication with GraceDB.
- exception gwcelery.tasks.gracedb.RetryableHTTPError(*args, **kwargs)[source]¶
Bases:
HTTPError
Exception class for server-side HTTP errors that we should retry.
- gwcelery.tasks.gracedb.catch_retryable_http_errors(f)[source]¶
Decorator to capture server-side errors that we should retry.
We retry HTTP status 502 (Bad Gateway), 503 (Service Unavailable), and 504 (Gateway Timeout). We also retry client side error codes 408 (Timeout), 409 (Conflicting URL), 429 (Too many requests).
- (task)gwcelery.tasks.gracedb.add_pipeline_preferred_event(superevent_id, event_id)[source]¶
Proxy that evaluates object once.
Proxy
will evaluate the object each time, while the promise will only evaluate it once.
- (task)gwcelery.tasks.gracedb.create_event(filecontents, search, pipeline, group, labels=())[source]¶
Create an event in GraceDB.
- (task)gwcelery.tasks.gracedb.create_label_with_log(log_message, label, tags, superevent_id)[source]¶
Create a label with a log for a superevent in GraceDB.
- (task)gwcelery.tasks.gracedb.create_signoff(status, comment, signoff_type, graceid)[source]¶
Create a signoff in GraceDB.
- (task)gwcelery.tasks.gracedb.create_voevent(graceid, voevent_type, **kwargs)[source]¶
Create a VOEvent.
- Returns:
The filename of the new VOEvent.
- Return type:
- (task)gwcelery.tasks.gracedb.expose(graceid)[source]¶
Expose an event to the public.
Notes
If
expose_to_public
is False, then this because a no-op.
- (task)gwcelery.tasks.gracedb.get_group(graceid)[source]¶
Retrieve the search field of an event from GraceDB.
- (task)gwcelery.tasks.gracedb.get_search(graceid)[source]¶
Retrieve the search field of an event from GraceDB.
- (task)gwcelery.tasks.gracedb.get_log(graceid)[source]¶
Get all log messages for an event in GraceDB.
- (task)gwcelery.tasks.gracedb.upload(filecontents, filename, graceid, message, tags=())[source]¶
Upload a file to GraceDB.
- (task)gwcelery.tasks.gracedb.get_superevents(query, **kwargs)[source]¶
List matching superevents in gracedb.
- Parameters:
*args – arguments passed to
GraceDb.superevents()
**kwargs – keyword arguments passed to
GraceDb.superevents()
- Returns:
superevents – The list of the superevents.
- Return type:
- (task)gwcelery.tasks.gracedb.remove_pipeline_preferred_event(superevent_id, event_id)[source]¶
Proxy that evaluates object once.
Proxy
will evaluate the object each time, while the promise will only evaluate it once.
- (task)gwcelery.tasks.gracedb.update_superevent(superevent_id, t_start=None, t_end=None, t_0=None, preferred_event=None, em_type=None, time_coinc_far=None, space_coinc_far=None)[source]¶
Update superevent information. Wrapper around
updateSuperevent()
- Parameters:
- (task)gwcelery.tasks.gracedb.create_superevent(graceid, t0, t_start, t_end)[source]¶
Create new superevent in GraceDB with graceid
- (task)gwcelery.tasks.gracedb.add_event_to_superevent(superevent_id, graceid)[source]¶
Add an event to a superevent in GraceDB.
- (task)gwcelery.tasks.gracedb.get_superevent_file_list(superevent_id)[source]¶
Get superevent file list from GraceDB.