job

Documentation

Index

• Constants
• type ActionOperator
  • func (o *ActionOperator) ExecAction(ctx context.Context, cfg config.Configuration, taskID, deploymentID string, ...) (bool, error)
• type COMPSsApplication
• type ContainerOptions
• type Environment
• type Execution
  • func (e *Execution) Execute(ctx context.Context) error
  • func (e *Execution) ExecuteAsync(ctx context.Context) (*prov.Action, time.Duration, error)
  • func (e *Execution) ResolveExecution(ctx context.Context) error
• type SubmissionParams

Constants

const (
	PyCOMPSsJobMonitoringActionType = "pycompss-job-monitoring"
)

Types

type ActionOperator

type ActionOperator struct {
}

ActionOperator holds function allowing to execute an action

func (*ActionOperator) ExecAction

func (o *ActionOperator) ExecAction(ctx context.Context, cfg config.Configuration, taskID, deploymentID string, action *prov.Action) (bool, error)

ExecAction allows to execute and action

type COMPSsApplication

type COMPSsApplication struct {
	Arguments     []string         `mapstructure:"arguments" json:"arguments,omitempty"`
	Command       string           `mapstructure:"command" json:"command,omitempty"`
	ContainerOpts ContainerOptions `mapstructure:"container_opts" json:"container_opts,omitempty"`
}

COMPSsApplication is the generated representation of org.eflows4hpc.pycompss.plugin.types.COMPSsApplication data type

type ContainerOptions

type ContainerOptions struct {
	ContainerCompssPath string `mapstructure:"container_compss_path" json:"container_compss_path,omitempty"`
	ContainerImage      string `mapstructure:"container_image" json:"container_image,omitempty"`
	ContainerOpts       string `mapstructure:"container_opts" json:"container_opts,omitempty"`
}

ContainerOptions is the generated representation of org.eflows4hpc.pycompss.plugin.types.ContainerOptions data type

type Environment

type Environment struct {
	// The endpoint of the pycomps server
	Endpoint string `mapstructure:"endpoint" json:"endpoint,omitempty"`
	// user used to connect to the cluster may be overridden by a workflow input
	UserName string `mapstructure:"user_name" json:"user_name,omitempty"`
}

Environment is the generated representation of org.eflows4hpc.pycompss.plugin.types.Environment data type

type Execution

type Execution struct {
	KV                     *api.KV
	Cfg                    config.Configuration
	DeploymentID           string
	TaskID                 string
	NodeName               string
	Operation              prov.Operation
	MonitoringTimeInterval time.Duration
	EnvInputs              []*operations.EnvInput
	VarInputsNames         []string
	// contains filtered or unexported fields
}

Execution holds job Execution properties

func (*Execution) Execute

func (e *Execution) Execute(ctx context.Context) error

Execute executes a synchronous operation

func (*Execution) ExecuteAsync

func (e *Execution) ExecuteAsync(ctx context.Context) (*prov.Action, time.Duration, error)

ExecuteAsync executes an asynchronous operation

func (*Execution) ResolveExecution

func (e *Execution) ResolveExecution(ctx context.Context) error

ResolveExecution resolves inputs and artifacts before the execution of an operation

type SubmissionParams

type SubmissionParams struct {
	CompssModules     []string `mapstructure:"compss_modules" json:"compss_modules,omitempty"`
	ExtraCompssOpts   string   `mapstructure:"extra_compss_opts" json:"extra_compss_opts,omitempty"`
	NumNodes          int      `mapstructure:"num_nodes" json:"num_nodes,omitempty"`
	PythonInterpreter string   `mapstructure:"python_interpreter" json:"python_interpreter,omitempty"`
	Qos               string   `mapstructure:"qos" json:"qos,omitempty"`
}

SubmissionParams is the generated representation of org.eflows4hpc.pycompss.plugin.types.SubmissionParams data type