avocado.core.status package
Submodules
avocado.core.status.repo module
- exception avocado.core.status.repo.StatusMsgMissingDataError
Bases:
Exception
Status message does not contain the required data.
- class avocado.core.status.repo.StatusRepo(job_id)
Bases:
object
Maintains tasks’ status related data and provides aggregated info.
Initializes a new StatusRepo
- Parameters:
job_id (str) – the job unique identification for which the messages are destined to.
- get_all_task_data(task_id)
Returns all data on a given task, by its ID.
- get_latest_task_data(task_id)
Returns the latest data on a given task, by its ID.
- get_result_set_for_tasks(task_ids)
Returns a set of results for the given tasks.
- get_task_data(task_id, index)
Returns the data on the index of a given task, by its ID.
- get_task_status(task_id)
- process_message(message)
- process_raw_message(raw_message)
- property result_stats
- status_journal_summary_pop()
avocado.core.status.server module
- class avocado.core.status.server.StatusServer(uri, repo)
Bases:
object
Server that listens for status messages and updates a StatusRepo.
Initializes a new StatusServer.
- Parameters:
uri (str) – either a “host:port” string or a path to a UNIX socket
repo (
avocado.core.status.repo.StatusRepo
) – the repository to use to process received status messages
- async cb(reader, _)
- close()
- async create_server()
- async serve_forever()
- property uri
avocado.core.status.utils module
- exception avocado.core.status.utils.StatusMsgInvalidJSONError
Bases:
Exception
Status message does not contain valid JSON.
- avocado.core.status.utils.json_base64_decode(dct)
base64 decode object hook for custom JSON encoding.
- avocado.core.status.utils.json_loads(data)
Loads and decodes JSON, with added base64 decoding.
- Parameters:
data – either bytes or a string. If bytes, will be decoded using the current default encoding.
- Raises:
- Returns:
decoded Python objects