[Backend] Cache - Add cache_enabled label for cache filtering

backend/src/apiserver/resource/resource_manager.go

@@ -286,6 +286,8 @@ func (r *ResourceManager) CreateRun(apiRun *api.Run) (*model.RunDetail, error) {
 
 	// Disable istio sidecar injection
 	workflow.SetAnnotationsToAllTemplates(util.AnnotationKeyIstioSidecarInject, util.AnnotationValueIstioSidecarInjectDisabled)
+	// Add a KFP specific annotation for cache service filtering
+	workflow.SetAnnotationsToAllTemplates(util.AnnotationKeyCacheEnabled, util.AnnotationValueCacheEnabled)
 	// Append provided parameter
 	workflow.OverrideParameters(parameters)
 

backend/src/common/util/consts.go

@@ -40,15 +40,17 @@ const (
 	// It captures whether the name of the owning ScheduledWorkflow.
 	LabelKeyWorkflowScheduledWorkflowName = constants.FullName + "/scheduledWorkflowName"
 
-
-	LabelKeyWorkflowRunId = "pipeline/runid"
+	LabelKeyWorkflowRunId               = "pipeline/runid"
 	LabelKeyWorkflowPersistedFinalState = "pipeline/persistedFinalState"
 
 	// LabelKeyWorkflowEpoch is a Workflow annotation key.
 	// It captures the the name of the Run.
 	AnnotationKeyRunName = "pipelines.kubeflow.org/run_name"
 
-	AnnotationKeyIstioSidecarInject = "sidecar.istio.io/inject"
-	AnnotationValueIstioSidecarInjectEnabled = "true"
+	AnnotationKeyIstioSidecarInject           = "sidecar.istio.io/inject"
+	AnnotationValueIstioSidecarInjectEnabled  = "true"
 	AnnotationValueIstioSidecarInjectDisabled = "false"
+
+	AnnotationKeyCacheEnabled   = "pipelines.kubeflow.org/cache_enabled"
+	AnnotationValueCacheEnabled = "true"
 )