TaskActionSpec
TaskActionSpec defines the desired state of TaskAction
Attributes
| Attribute | Type | Description |
|---|---|---|
| RunName | string | RunName is the name of the run this action belongs to; it must be between 1 and 30 characters long. |
| Project | string | Project this action belongs to; it must be between 1 and 63 characters long. |
| Domain | string | Domain this action belongs to; it must be between 1 and 63 characters long. |
| ActionName | string | ActionName is the unique name of this action within the run; it must be between 1 and 30 characters long. |
| ParentActionName | string | ParentActionName is the optional name of the parent action; it must be between 1 and 30 characters long if set. |
| InputURI | string | InputURI is the path to the input data for this action; it must have a minimum length of 1. |
| RunOutputBase | string | RunOutputBase is the base path where this action should write its output; it must have a minimum length of 1. |
| CacheKey | string | CacheKey enables cache lookup/writeback for this task action when set, propagated from workflow.TaskAction.cache_key; it has a maximum length of 256. |
| TaskType | string | TaskType identifies which plugin handles this task (e.g. "container", "spark", "ray"); it must be between 1 and 63 characters long. |
| ShortName | string | ShortName is the human-readable display name for this task; it has a maximum length of 63. |
| TaskTemplate | array | TaskTemplate is the proto-serialized core.TaskTemplate stored inline in etcd. |
| EnvVars | object | EnvVars are run-scoped environment variables projected from RunSpec for executor runtime use. |
| Interruptible | boolean | Interruptible is the run-scoped interruptibility override projected from RunSpec. |
| Group | string | Group is the group this action belongs to, if applicable; it has a maximum length of 256. |
Constructor
Signature
def TaskActionSpec(
RunName: string,
Project: string,
Domain: string,
ActionName: string,
ParentActionName: string = null,
InputURI: string,
RunOutputBase: string,
CacheKey: string = null,
TaskType: string,
ShortName: string = null,
TaskTemplate: bytes,
EnvVars: map[string]string = null,
Interruptible: boolean = null,
Group: string = null
) - > null
Parameters
| Name | Type | Description |
|---|---|---|
| RunName | string | The name of the run this action belongs to. Required, minimum length 1, maximum length 30. |
| Project | string | The project this action belongs to. Required, minimum length 1, maximum length 63. |
| Domain | string | The domain this action belongs to. Required, minimum length 1, maximum length 63. |
| ActionName | string | The unique name of this action within the run. Required, minimum length 1, maximum length 30. |
| ParentActionName | string = null | The optional name of the parent action. Minimum length 1, maximum length 30. |
| InputURI | string | The path to the input data for this action. Required, minimum length 1. |
| RunOutputBase | string | The base path where this action should write its output. Required, minimum length 1. |
| CacheKey | string = null | Enables cache lookup/writeback for this task action when set. Propagated from workflow.TaskAction.cache_key. Maximum length 256. |
| TaskType | string | Identifies which plugin handles this task (e.g., 'container', 'spark', 'ray'). Required, minimum length 1, maximum length 63. |
| ShortName | string = null | The human-readable display name for this task. Maximum length 63. |
| TaskTemplate | bytes | The proto-serialized core.TaskTemplate stored inline in etcd. Required. |
| EnvVars | map[string]string = null | Run-scoped environment variables projected from RunSpec for executor runtime use. |
| Interruptible | boolean = null | The run-scoped interruptibility override projected from RunSpec. |
| Group | string = null | The group this action belongs to, if applicable. Maximum length 256. |
Methods
GetActionSpec()
@classmethod
def GetActionSpec() - > *workflow.ActionSpec, error
Retrieves the action specification.
Returns
| Type | Description |
|---|---|
*workflow.ActionSpec, error | The action specification and an error, if any. |
SetActionSpec()
@classmethod
def SetActionSpec(
spec: *workflow.ActionSpec
) - > error
Sets the action specification.
Parameters
| Name | Type | Description |
|---|---|---|
| spec | *workflow.ActionSpec | The action specification to set. |
Returns
| Type | Description |
|---|---|
error | An error, if any occurred during the setting process. |