avocado.core.task package

Submodules

avocado.core.task.runtime module

class avocado.core.task.runtime.PostRuntimeTask(task, satisfiable_deps_execution_statuses=None)

Bases: PrePostRuntimeTaskMixin

Runtime task for tasks run after test

Instantiates a new RuntimeTask.

Parameters:

  • task (avocado.core.nrunner.Task) – The task to keep additional information about

  • satisfiable_deps_execution_statuses (list of test results.) – The dependency result types that satisfy the execution of this RuntimeTask.

category = 'post_test'
dispatcher

alias of TestPostDispatcher

class avocado.core.task.runtime.PrePostRuntimeTaskMixin(task, satisfiable_deps_execution_statuses=None)

Bases: RuntimeTask

Common utilities for PrePostRuntimeTask implementations.

Instantiates a new RuntimeTask.

Parameters:

  • task (avocado.core.nrunner.Task) – The task to keep additional information about

  • satisfiable_deps_execution_statuses (list of test results.) – The dependency result types that satisfy the execution of this RuntimeTask.

classmethod get_tasks_from_test_task(test_task, no_digits, base_dir, test_suite_name=None, status_server_uri=None, job_id=None, suite_config=None)

Creates runtime tasks for preTest task from test task.

Parameters:

  • test_task (avocado.core.task.runtime.RuntimeTask) – Runtime test task.

  • no_digits (int) – number of digits of the test uid

  • base_dir (str) – Path to the job base directory.

  • test_suite_name (str) – test suite name which this test is related to

  • status_server_uri (list) – the URIs for the status servers that this task should send updates to.

  • job_id (str) – the ID of the job, for authenticating messages that get sent to the destination job’s status server and will make into the job’s results.

  • suite_config (dict) – Configuration dict relevant for the whole suite.

Returns:

Pre/Post RuntimeTasks of the dependencies from runnable

Return type:

list

class avocado.core.task.runtime.PreRuntimeTask(task, satisfiable_deps_execution_statuses=None)

Bases: PrePostRuntimeTaskMixin

Runtime task for tasks run before test

Instantiates a new RuntimeTask.

Parameters:

  • task (avocado.core.nrunner.Task) – The task to keep additional information about

  • satisfiable_deps_execution_statuses (list of test results.) – The dependency result types that satisfy the execution of this RuntimeTask.

category = 'pre_test'
dispatcher

alias of TestPreDispatcher

class avocado.core.task.runtime.RuntimeTask(task, satisfiable_deps_execution_statuses=None)

Bases: RuntimeTaskMixin

Task with extra status information on its life cycle status.

The avocado.core.nrunner.Task class contains information that is necessary to describe its persistence and execution by itself.

This class wraps a avocado.core.nrunner.Task, with extra information about its execution by a spawner within a state machine.

Instantiates a new RuntimeTask.

Parameters:

  • task (avocado.core.nrunner.Task) – The task to keep additional information about

  • satisfiable_deps_execution_statuses (list of test results.) – The dependency result types that satisfy the execution of this RuntimeTask.

are_dependencies_finished()
can_run()
category = 'test'
execution_timeout

Timeout limit for the completion of the task execution

get_finished_dependencies()

Returns all dependencies which already finished.

is_cacheable

Flag to detect if the task should be save to cache

property result
property satisfiable_deps_execution_statuses
spawner_handle

A handle that may be set by a spawner, and that may be spawner implementation specific, to keep track the task execution. This may be a PID, a container ID, a FQDN+PID etc.

spawning_result

The result of the spawning of a Task

status

The task status, a value from the enum avocado.core.task.runtime.RuntimeTaskStatus

task

The avocado.core.nrunner.Task

class avocado.core.task.runtime.RuntimeTaskGraph(tests, test_suite_name, status_server_uri, job_id, base_dir, suite_config=None)

Bases: object

Graph representing dependencies between runtime tasks.

Instantiates a new RuntimeTaskGraph.

From the list of tests, it will create runtime tasks and connects them inside the graph by its dependencies.

Parameters:

  • tests (list) – runnables from test suite

  • test_suite_name (str) – test suite name which this test is related to

  • status_server_uri (list) – the URIs for the status servers that this task should send updates to.

  • job_id (str) – the ID of the job, for authenticating messages that get sent to the destination job’s status server and will make into the job’s results.

  • base_dir (str) – Path to the job base directory.

  • suite_config (dict) – Configuration dict relevant for the whole suite.

get_tasks_in_topological_order()

Computes the topological order of runtime tasks in graph

Returns:

runtime tasks in topological order

Return type:

list

class avocado.core.task.runtime.RuntimeTaskMixin

Bases: object

Common utilities for RuntimeTask implementations.

classmethod from_runnable(runnable, no_digits, index, base_dir, test_suite_name=None, status_server_uri=None, job_id=None, satisfiable_deps_execution_statuses=None)

Creates runtime task for test from runnable

Parameters:

  • runnable (avocado.core.nrunner.Runnable) – the “description” of what the task should run.

  • no_digits (int) – number of digits of the test uid

  • index (int) – index of tests inside test suite

  • base_dir (str) – Path to the job base directory.

  • test_suite_name (str) – test suite name which this test is related to

  • status_server_uri (list) – the URIs for the status servers that this task should send updates to.

  • job_id (str) – the ID of the job, for authenticating messages that get sent to the destination job’s status server and will make into the job’s results.

  • satisfiable_deps_execution_statuses (list of test results.) – The dependency result types that satisfy the execution of this RuntimeTask.

Returns:

RuntimeTask of the test from runnable

classmethod get_identifier(runnable, no_digits, index, test_suite_name=None)
class avocado.core.task.runtime.RuntimeTaskStatus(value, names=None, *, module=None, qualname=None, type=None, start=1, boundary=None)

Bases: Enum

FAILFAST = 'FINISHED FAILFAST'
FAIL_START = 'FINISHED FAILING TO START'
FAIL_TRIAGE = 'FINISHED WITH FAILURE ON TRIAGE'
FINISHED = 'FINISHED'
INTERRUPTED = 'FINISHED INTERRUPTED'
IN_CACHE = 'FINISHED IN CACHE'
STARTED = 'STARTED'
TIMEOUT = 'FINISHED TIMEOUT'
WAIT = 'WAITING'
WAIT_DEPENDENCIES = 'WAITING DEPENDENCIES'
static finished_statuses()

avocado.core.task.statemachine module

class avocado.core.task.statemachine.TaskStateMachine(tasks, status_repo)

Bases: object

Represents all phases that a task can go through its life.

async abort(status_reason=None)

Abort all non-started tasks.

This method will move all non-started tasks to finished with a specific reason.

Parameters:

status_reason – string reason. Optional.

async abort_queue(queue_name, status_reason=None)

Abort all tasks inside a specific queue adding a status reason.

Parameters:

  • queue_name – a string with the queue name.

  • status_reason – string reason. Optional.

async add_new_task(runtime_task)
property cache_lock
property complete
async finish_task(runtime_task, status_reason=None)

Include a task to the finished queue with a specific reason.

This method is assuming that you have removed (pop) the task from the original queue.

Parameters:

  • runtime_task – A running task object.

  • status_reason – string reason. Optional.

property finished
property lock
property monitored
property ready
property requested
property started
property task_size
property tasks_by_id
property triaging
class avocado.core.task.statemachine.Worker(state_machine, spawner, max_triaging=None, max_running=None, task_timeout=None, failfast=False)

Bases: object

async bootstrap()

Reads from requested, moves into triaging.

async monitor()

Reads from started, moves into finished.

async run()

Pushes Tasks forward and makes them do something with their lives.

async start()

Reads from ready, moves into either: started or finished.

async terminate_tasks_interrupted()

Terminate all running tasks with an interrupted message.

async terminate_tasks_timeout()

Terminate all running tasks with a timeout message.

async triage()

Reads from triaging, moves into either: ready or finished.

Module contents