chore: Fix scale up or down retry, too many event (#186)

Signed-off-by: xieydd <xieydd@gmail.com>

agent/Makefile

@@ -175,8 +175,8 @@ swag: swag-install
 	swag init -g ./cmd/agent/main.go --parseDependency --output ./pkg/docs 
 
 build-image: build-local
-	docker build -t ${BASE_REGISTRY}/${BASE_REGISTRY_USER}/modelz-agent:dev -f Dockerfile ./bin
-	docker push ${BASE_REGISTRY}/${BASE_REGISTRY_USER}/modelz-agent:dev
+	docker build -t ${BASE_REGISTRY}/${BASE_REGISTRY_USER}/openmodelz-agent:dev -f Dockerfile ./bin
+	docker push ${BASE_REGISTRY}/${BASE_REGISTRY_USER}/openmodelz-agent:dev
 
 release:
 	@if [ ! -f ".release-env" ]; then \

agent/api/types/requests.go

@@ -8,6 +8,7 @@ type ScaleServiceRequest struct {
 	ServiceName  string `json:"serviceName"`
 	Replicas     uint64 `json:"replicas"`
 	EventMessage string `json:"eventMessage"`
+	Attempt      int    `json:"attempt"`
 }
 
 // DeleteFunctionRequest delete a deployed function

agent/pkg/runtime/inference_replicas.go

@@ -64,9 +64,12 @@ func (r generalRuntime) InferenceScale(ctx context.Context, namespace string,
 	}
 
 	if r.eventEnabled {
-		err = r.eventRecorder.CreateDeploymentEvent(namespace, deployment.Name, event, req.EventMessage)
-		if err != nil {
-			return err
+		// Only create event when the first time scale up/down
+		if req.Attempt == 0 {
+			err = r.eventRecorder.CreateDeploymentEvent(namespace, deployment.Name, event, req.EventMessage)
+			if err != nil {
+				return err
+			}
 		}
 	}
 

agent/pkg/scaling/function_scaler.go

@@ -154,7 +154,8 @@ func (s *InferenceScaler) Scale(ctx context.Context,
 			if err := s.runtime.InferenceScale(ctx, namespace, types.ScaleServiceRequest{
 				ServiceName:  inferenceName,
 				Replicas:     minReplicas,
-				EventMessage: fmt.Sprintf("scale up to minimum replicas %d", minReplicas),
+				EventMessage: fmt.Sprintf("scale up to replicas %d", minReplicas),
+				Attempt:      attempt,
 			}, inf); err != nil {
 				return err
 			}