avocado.core.task package¶
Submodules¶
avocado.core.task.runtime module¶
-
class
avocado.core.task.runtime.
PreRuntimeTask
(task)¶ Bases:
avocado.core.task.runtime.RuntimeTask
Instantiates a new RuntimeTask.
Parameters: task ( avocado.core.nrunner.Task
) – The task to keep additional information about-
classmethod
from_runnable
(pre_runnable, status_server_uri=None, job_id=None)¶ Creates runtime task for pre_test plugin from runnable
Parameters: - pre_runnable – the “description” of what the task should run.
- 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.
Returns: RuntimeTask of the test from runnable
-
classmethod
get_pre_tasks_from_runnable
(runnable, status_server_uri=None, job_id=None)¶ Creates runtime tasks for preTest task from runnable
Parameters: - runnable (
avocado.core.nrunner.Runnable
) – the “description” of what the task should run. - 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.
Returns: Pre RuntimeTasks of the dependencies from runnable
Return type: - runnable (
-
classmethod
-
class
avocado.core.task.runtime.
RuntimeTask
(task)¶ Bases:
object
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-
are_dependencies_finished
()¶
-
can_run
()¶
-
execution_timeout
= None¶ Timeout limit for the completion of the task execution
-
classmethod
from_runnable
(runnable, no_digits, index, variant, test_suite_name=None, status_server_uri=None, job_id=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
- 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.
Returns: RuntimeTask of the test from runnable
- runnable (
-
get_finished_dependencies
()¶ Returns all dependencies which already finished.
-
result
= None¶ Information about task result when it is finished
-
spawner_handle
= None¶ 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
= None¶ The result of the spawning of a Task
-
status
= None¶ Additional descriptive information about the task status
-
task
= None¶ The
avocado.core.nrunner.Task
-
-
class
avocado.core.task.runtime.
RuntimeTaskGraph
(tests, test_suite_name, status_server_uri, job_id)¶ 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) – variants of 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.
-
class
avocado.core.task.runtime.
RuntimeTaskStatus
¶ Bases:
enum.Enum
An enumeration.
-
FAILFAST
= 'FINISHED FAILFAST'¶
-
FAIL_START
= 'FINISHED FAILING TO START'¶
-
FAIL_TRIAGE
= 'FINISHED WITH FAILURE ON TRIAGE'¶
-
FINISHED
= 'FINISHED'¶
-
IN_CACHE
= 'FINISHED IN CACHE'¶
-
STARTED
= 'STARTED'¶
-
TIMEOUT
= 'FINISHED TIMEOUT'¶
-
WAIT
= 'WAITING'¶
-
WAIT_DEPENDENCIES
= 'WAITING DEPENDENCIES'¶
-
finished_statuses
= <function RuntimeTaskStatus.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.
-
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.
-
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.
-
cache_lock
¶
-
complete
¶
-
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.
-
finished
¶
-
lock
¶
-
monitored
¶
-
ready
¶
-
requested
¶
-
started
¶
-
triaging
¶
-
-
class
avocado.core.task.statemachine.
Worker
(state_machine, spawner, max_triaging=None, max_running=None, task_timeout=None, failfast=False)¶ Bases:
object
-
bootstrap
()¶ Reads from requested, moves into triaging.
-
monitor
()¶ Reads from started, moves into finished.
-
run
()¶ Pushes Tasks forward and makes them do something with their lives.
-
start
()¶ Reads from ready, moves into either: started or finished.
-
terminate_tasks_timeout
()¶ Terminate all running tasks with timeout message.
-
triage
()¶ Reads from triaging, moves into either: ready or finished.
-