gwcelery.tasks.gracedb module

Communication with GraceDB.

exception gwcelery.tasks.gracedb.RetryableHTTPError(*args, **kwargs)

Bases: HTTPError

Exception class for server-side HTTP errors that we should retry.

gwcelery.tasks.gracedb.catch_retryable_http_errors(f)

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).

gwcelery.tasks.gracedb.task(*args, **kwargs)

(task)gwcelery.tasks.gracedb.add_pipeline_preferred_event(superevent_id, event_id)

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=())

Create an event in GraceDB.

(task)gwcelery.tasks.gracedb.create_label(label, graceid)

Create a label in GraceDB.

(task)gwcelery.tasks.gracedb.remove_label(label, graceid)

Remove a label in GraceDB.

(task)gwcelery.tasks.gracedb.create_signoff(status, comment, signoff_type, graceid)

Create a signoff in GraceDB.

(task)gwcelery.tasks.gracedb.create_tag(filename, tag, graceid)

Create a tag in GraceDB.

(task)gwcelery.tasks.gracedb.create_voevent(graceid, voevent_type, **kwargs)

Create a VOEvent.

Returns:

The filename of the new VOEvent.

Return type:

str

(task)gwcelery.tasks.gracedb.download(filename, graceid)

Download a file from GraceDB.

(task)gwcelery.tasks.gracedb.expose(graceid)

Expose an event to the public.

Notes

If expose_to_public is False, then this because a no-op.

(task)gwcelery.tasks.gracedb.get_events(query, **kwargs)

Get events from GraceDB.

(task)gwcelery.tasks.gracedb.get_event(graceid)

Retrieve an event from GraceDB.

(task)gwcelery.tasks.gracedb.get_group(graceid)

Retrieve the search field of an event from GraceDB.

(task)gwcelery.tasks.gracedb.get_search(graceid)

Retrieve the search field of an event from GraceDB.

(task)gwcelery.tasks.gracedb.get_labels(graceid)

Get all labels for an event in GraceDB.

(task)gwcelery.tasks.gracedb.get_log(graceid)

Get all log messages for an event in GraceDB.

(task)gwcelery.tasks.gracedb.get_superevent(graceid)

Retrieve a superevent from GraceDB.

(task)gwcelery.tasks.gracedb.replace_event(graceid, payload)

Get an event from GraceDB.

(task)gwcelery.tasks.gracedb.upload(filecontents, filename, graceid, message, tags=())

Upload a file to GraceDB.

(task)gwcelery.tasks.gracedb.get_superevents(query, **kwargs)

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:

list

(task)gwcelery.tasks.gracedb.remove_pipeline_preferred_event(superevent_id, event_id)

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)

Update superevent information. Wrapper around updateSuperevent()

Parameters:

• superevent_id (str) – superevent uid

• t_start (float) – start of superevent time window, unchanged if None

• t_end (float) – end of superevent time window, unchanged if None

• t_0 (float) – superevent t_0, unchanged if None

• preferred_event (str) – uid of the preferred event, unchanged if None

(task)gwcelery.tasks.gracedb.create_superevent(graceid, t0, t_start, t_end)

Create new superevent in GraceDB with graceid

Parameters:

• graceid (str) – graceid with which superevent is created.

• t0 (float) – t_0 parameter of superevent

• t_start (float) – t_start parameter of superevent

• t_end (float) – t_end parameter of superevent

(task)gwcelery.tasks.gracedb.add_event_to_superevent(superevent_id, graceid)

Add an event to a superevent in GraceDB.