Documentation
¶
Index ¶
- func MakeLiteralForParams(serialize map[string]interface{}, parameters map[string]*core.Parameter) (map[string]*core.Literal, error)
- func MakeLiteralForTypes(serialize map[string]interface{}, types map[string]*core.LiteralType) (map[string]*core.Literal, error)
- func MakeLiteralForVariables(serialize map[string]interface{}, variables map[string]*core.Variable) (map[string]*core.Literal, error)
- func RemoteCreateCommand() *cobra.Command
- type ExecutionConfig
- type ExecutionParams
- type ExecutionType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MakeLiteralForParams ¶
func MakeLiteralForParams(serialize map[string]interface{}, parameters map[string]*core.Parameter) (map[string]*core.Literal, error)
MakeLiteralForParams builds a map of literals for the provided serialized values. If a provided value does not have a corresponding parameter or if that parameter is invalid (e.g. doesn't have Type property populated), it returns an error.
func MakeLiteralForTypes ¶ added in v0.1.15
func MakeLiteralForTypes(serialize map[string]interface{}, types map[string]*core.LiteralType) (map[string]*core.Literal, error)
MakeLiteralForTypes builds a map of literals for the provided serialized values. If a provided value does not have a corresponding type or if it fails to create a literal for the given type and value, it returns an error.
func MakeLiteralForVariables ¶
func MakeLiteralForVariables(serialize map[string]interface{}, variables map[string]*core.Variable) (map[string]*core.Literal, error)
TODO: Move all functions to flyteidl MakeLiteralForVariables builds a map of literals for the provided serialized values. If a provided value does not have a corresponding variable or if that variable is invalid (e.g. doesn't have Type property populated), it returns an error.
func RemoteCreateCommand ¶
RemoteCreateCommand will return create Flyte resource commands
Types ¶
type ExecutionConfig ¶
type ExecutionConfig struct {
// pflag section
ExecFile string `` /* 137-byte string literal not displayed */
TargetDomain string `json:"targetDomain" pflag:",project where execution needs to be created. If not specified configured domain would be used."`
TargetProject string `json:"targetProject" pflag:",project where execution needs to be created. If not specified configured project would be used."`
KubeServiceAcct string `json:"kubeServiceAcct" pflag:",kubernetes service account AuthRole for launching execution."`
IamRoleARN string `json:"iamRoleARN" pflag:",iam role ARN AuthRole for launching execution."`
Relaunch string `json:"relaunch" pflag:",execution id to be relaunched."`
Recover string `json:"recover" pflag:",execution id to be recreated from the last known failure point."`
DryRun bool `json:"dryRun" pflag:",execute command without making any modifications."`
Version string `json:"version" pflag:",specify version of execution workflow/task."`
ClusterPool string `json:"clusterPool" pflag:",specify which cluster pool to assign execution to."`
OverwriteCache bool `` /* 191-byte string literal not displayed */
// Non plfag section is read from the execution config generated by get task/launch plan
Workflow string `json:"workflow,omitempty"`
Task string `json:"task,omitempty"`
Inputs map[string]interface{} `json:"inputs" pflag:"-"`
Envs map[string]string `json:"envs" pflag:"-"`
}
ExecutionConfig hold configuration for create execution flags and configuration of the actual task or workflow to be launched.
func (ExecutionConfig) GetPFlagSet ¶
func (cfg ExecutionConfig) GetPFlagSet(prefix string) *pflag.FlagSet
GetPFlagSet will return strongly types pflags for all fields in ExecutionConfig and its nested types. The format of the flags is json-name.json-sub-name... etc.
type ExecutionParams ¶
type ExecutionParams struct {
// contains filtered or unexported fields
}
type ExecutionType ¶ added in v0.1.6
type ExecutionType int
const ( Task ExecutionType = iota Workflow Relaunch Recover )
Source Files