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
()¶
- type (TaskType) –