create

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
  • func (cfg ExecutionConfig) GetPFlagSet(prefix string) *pflag.FlagSet
• type ExecutionParams
• type ExecutionType

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

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

func RemoteCreateCommand() *cobra.Command

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

type ExecutionType int

const (
	Task ExecutionType = iota
	Workflow
	Relaunch
	Recover
)