datasciencepipelines

Documentation

Overview

Package datasciencepipelines provides utility functions to config Data Science Pipelines: Pipeline solution for end to end MLOps workflows that support the Kubeflow Pipelines SDK, Tekton and Argo Workflows. +groupName=datasciencecluster.opendatahub.io

Index

• Variables
• func SetExistingArgoCondition(conditions *[]conditionsv1.Condition, reason, message string)
• func UnmanagedArgoWorkFlowExists(ctx context.Context, cli client.Client) error
• type DataSciencePipelines
  • func (in *DataSciencePipelines) DeepCopy() *DataSciencePipelines
  • func (in *DataSciencePipelines) DeepCopyInto(out *DataSciencePipelines)
  • func (d *DataSciencePipelines) GetComponentName() string
  • func (d *DataSciencePipelines) OverrideManifests(ctx context.Context, _ cluster.Platform) error
  • func (d *DataSciencePipelines) ReconcileComponent(ctx context.Context, cli client.Client, logger logr.Logger, ...) error

Variables

var (
	ComponentName   = "data-science-pipelines-operator"
	Path            = deploy.DefaultManifestPath + "/" + ComponentName + "/base"
	OverlayPath     = deploy.DefaultManifestPath + "/" + ComponentName + "/overlays"
	ArgoWorkflowCRD = "workflows.argoproj.io"
)

Functions

func SetExistingArgoCondition

func SetExistingArgoCondition(conditions *[]conditionsv1.Condition, reason, message string)

func UnmanagedArgoWorkFlowExists

func UnmanagedArgoWorkFlowExists(ctx context.Context,
	cli client.Client) error

Types

type DataSciencePipelines

type DataSciencePipelines struct {
	components.Component `json:""`
}

DataSciencePipelines struct holds the configuration for the DataSciencePipelines component. +kubebuilder:object:generate=true

func (*DataSciencePipelines) DeepCopy

func (in *DataSciencePipelines) DeepCopy() *DataSciencePipelines

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataSciencePipelines.

func (*DataSciencePipelines) DeepCopyInto

func (in *DataSciencePipelines) DeepCopyInto(out *DataSciencePipelines)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DataSciencePipelines) GetComponentName

func (d *DataSciencePipelines) GetComponentName() string

func (*DataSciencePipelines) OverrideManifests

func (d *DataSciencePipelines) OverrideManifests(ctx context.Context, _ cluster.Platform) error

func (*DataSciencePipelines) ReconcileComponent

func (d *DataSciencePipelines) ReconcileComponent(ctx context.Context,
	cli client.Client,
	logger logr.Logger,
	owner metav1.Object,
	dscispec *dsciv1.DSCInitializationSpec,
	platform cluster.Platform,
	_ bool,
) error