component

package
v2.0.0-...-6fac617 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 25, 2022 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source
const (
	VolumePathKFPLauncher = "/kfp-launcher"
	KFPLauncherPath       = VolumePathKFPLauncher + "/launch"

	// Env var names
	EnvPodName = "KFP_POD_NAME"
	EnvPodUID  = "KFP_POD_UID"

	// Env vars in metadata-grpc-configmap
	EnvMetadataHost = "METADATA_GRPC_SERVICE_HOST"
	EnvMetadataPort = "METADATA_GRPC_SERVICE_PORT"
)
View Source
const OutputMetadataFilepath = "/tmp/kfp_outputs/output_metadata.json"

Variables

This section is empty.

Functions

func CopyThisBinary

func CopyThisBinary(destination string) (err error)

CopyThisBinary copies the running binary into destination path.

Types

type ImportLauncher

type ImportLauncher struct {
	// contains filtered or unexported fields
}

func NewImporterLauncher

func NewImporterLauncher(ctx context.Context, componentSpecJSON, importerSpecJSON, taskSpecJSON string, launcherV2Opts *LauncherV2Options, importerLauncherOpts *ImporterLauncherOptions) (l *ImportLauncher, err error)

func (*ImportLauncher) Execute

func (l *ImportLauncher) Execute(ctx context.Context) (err error)

func (*ImportLauncher) ImportSpecToMLMDArtifact

func (l *ImportLauncher) ImportSpecToMLMDArtifact(ctx context.Context) (artifact *pb.Artifact, err error)

type ImporterLauncherOptions

type ImporterLauncherOptions struct {
	// required, pipeline context name
	PipelineName string
	// required, KFP run ID
	RunID string
	// required, parent DAG execution ID
	ParentDagID int64
}

type LauncherV2

type LauncherV2 struct {
	// contains filtered or unexported fields
}

func NewLauncherV2

func NewLauncherV2(ctx context.Context, executionID int64, executorInputJSON, componentSpecJSON string, cmdArgs []string, opts *LauncherV2Options) (l *LauncherV2, err error)

func (*LauncherV2) Execute

func (l *LauncherV2) Execute(ctx context.Context) (err error)

func (*LauncherV2) Info

func (l *LauncherV2) Info() string

type LauncherV2Options

type LauncherV2Options struct {
	Namespace,
	PodName,
	PodUID,
	MLMDServerAddress,
	MLMDServerPort,
	PipelineName,
	RunID string
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL