avocado.core.task package

Submodules

avocado.core.task.runtime module

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

execution_timeout

Timeout limit for the completion of the task execution

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

Additional descriptive information about the task status

task

The avocado.core.nrunner.Task

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.

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 ready

property requested

property started

property triaging

class avocado.core.task.statemachine.Worker(state_machine, spawner, max_triaging=None, max_running=None, task_timeout=None)

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

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

Module contents