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

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 `` /* 136-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."`
	// Non plfag section is read from the execution config generated by get task/launchplan
	Workflow string                 `json:"workflow,omitempty"`
	Task     string                 `json:"task,omitempty"`
	Version  string                 `json:"version"`
	Inputs   map[string]interface{} `json:"inputs"`
}

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
)

type ProjectConfig

type ProjectConfig struct {
	ID          string            `json:"id" pflag:",id for the project specified as argument."`
	Name        string            `json:"name" pflag:",name for the project specified as argument."`
	File        string            `json:"file" pflag:",file for the project definition."`
	Description string            `json:"description" pflag:",description for the project specified as argument."`
	Labels      map[string]string `json:"labels" pflag:",labels for the project specified as argument."`
}

ProjectConfig Config hold configuration for project create flags.

func (ProjectConfig) GetPFlagSet

func (cfg ProjectConfig) GetPFlagSet(prefix string) *pflag.FlagSet

GetPFlagSet will return strongly types pflags for all fields in ProjectConfig and its nested types. The format of the flags is json-name.json-sub-name... etc.