eqi.core.task module

class eqi.core.task.TaskType

Bases: enum.Enum

An enumeration.

ENCODING = 'ENCODING'

EXECUTION = 'EXECUTION'

ENCODING_AND_EXECUTION = 'ENCODING_AND_EXECUTION'

OTHER = 'OTHER'

class eqi.core.task.Task(type, requirements=None, name=None, model='default', resume_level=<ResumeLevel.BASIC: 'For the tasks creating run directories, the resume checks if an unfinished task created such directory. If such directory is available, this is automatically removed before the start of the resumed task'>, **params)

Bases: object

Represents a piece of work to be executed by QCG-PilotJob Manager

Parameters:

• type (TaskType) –

  The type of the task. Allowed tasks are: ENCODING, EXECUTION, ENCODING_AND_EXECUTION,

  and OTHER (currently not supported)

• requirements (TaskRequirements, optional) – The requirements for the Task
• name (str, optional) – name of the Task, if not provided the name will take a value of type
• model (str, optional) – Allows to set the flavour of execution of task adjusted to a given resource. At the moment of writing a user can select from the following models: threads, intelmpi, openmpi, srunmpi, default
• resume_level (ResumeLevel, optional) – The resume level applied for a task.
• params (kwargs) – additional parameters that may be used by specific Task types

get_type()

get_requirements()

get_model()

get_resume_level()

get_params()

get_name()