ewoksjob.events.readers.sqlite3.Sqlite3EwoksEventReader#

class ewoksjob.events.readers.sqlite3.Sqlite3EwoksEventReader(uri, **_)[source]#

Bases: EwoksEventReader

Parameters:

uri (str) –

close()[source]#
static dereference_data_uris(event)#
Parameters:

event (Dict[str, str]) –

Return type:

None

static event_passes_filter(event, starttime=None, endtime=None)#
Parameters:
  • event (Dict[str, str]) –

  • starttime (Optional[datetime]) –

  • endtime (Optional[datetime]) –

Return type:

bool

get_events(**filters)[source]#

Returns all currently available events matching the filter.

Return type:

Iterator[Dict[str, str]]

get_events_with_variables(*args, **kwargs)#

get_events with URI dereferencing.

Return type:

Iterable[Dict[str, str]]

get_full_job_events(**filters)#

Returns events grouped by “job_id”. When one event matches the filter, all events with the “job_id” are returned.

Return type:

Iterable[Tuple[Dict[str, str]]]

get_full_job_events_with_variables(**filters)#

get_full_job_events with URI dereferencing.

Return type:

Iterable[Tuple[Dict[str, str]]]

poll_events(timeout=None, stop_event=None, interval=0.1, **filters)#

Yield events matching the filter until timeout is reached.

Parameters:

stop_event (Optional[Event]) –

Return type:

Iterable[Dict[str, str]]

poll_events_with_variables(*args, **kwargs)#

get_events with URI dereferencing.

Return type:

Iterable[Dict[str, str]]

static split_filter(starttime=None, endtime=None, **is_equal_filter)#

Splits the filter

to be applied on the list of events fetched from the database

Parameters:
  • starttime (Optional[datetime]) –

  • endtime (Optional[datetime]) –

Return type:

Tuple[dict, dict]

wait_events(**kwargs)[source]#

Yield events matching the filter until timeout is reached.

Return type:

Iterator[Dict[str, str]]

wait_events_with_variables(*args, **kwargs)#

get_events with URI dereferencing.

Return type:

Iterable[Dict[str, str]]