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).
- (task)gwcelery.tasks.gracedb.add_pipeline_preferred_event(*args, **kwargs)[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_voevent(*args, **kwargs)[source]¶
Create a VOEvent.
- Returns:
The filename of the new VOEvent.
- Return type:
- (task)gwcelery.tasks.gracedb.expose(*args, **kwargs)[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(*args, **kwargs)[source]¶
Retrieve the search field of an event from GraceDB.
- (task)gwcelery.tasks.gracedb.get_search(*args, **kwargs)[source]¶
Retrieve the search field of an event from GraceDB.
- (task)gwcelery.tasks.gracedb.get_labels(*args, **kwargs)[source]¶
Get all labels for an event in GraceDB.
- (task)gwcelery.tasks.gracedb.get_log(*args, **kwargs)[source]¶
Get all log messages for an event in GraceDB.
- (task)gwcelery.tasks.gracedb.get_superevent(*args, **kwargs)[source]¶
Retrieve a superevent from GraceDB.
- (task)gwcelery.tasks.gracedb.get_superevents(*args, **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(*args, **kwargs)[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(*args, **kwargs)[source]¶
Update superevent information. Wrapper around
updateSuperevent()
- Parameters: