LaunchAndCheckSubTasksState iterates over each subtask performing operations to transition them to a terminal state.

NewSubtaskExecutionContext constructs a SubTaskExecutionContext using the provided parameters.

NewSubtaskExecutionID constructs a SubTaskExecutionID using the provided parameters.

NewSubtaskExecutionMetadata constructs a SubTaskExecutionMetadata using the provided parameters.

RemoteClusterConfig reads secret values from paths specified in the config to initialize a Kubernetes rest client Config.

TerminateSubTasks performs operations to gracefully terminate all subtasks.

Config defines custom config for K8s Array plugin.

SubTaskExecutionContext wraps the core TaskExecutionContext so that the k8s array task context can be used within the pod plugin.

SubTaskExecutionID wraps the core TaskExecutionID to customize the generated pod name.

SubTaskExecutionMetadata wraps the core TaskExecutionMetadata to customize the TaskExecutionID.

SubTaskReader wraps the core TaskReader to customize the task template task type and version.