chore(model): fix deployment reconciliation (#459)

Because

- avoid having false state in etcd

This commit

- fix marking model state as `STATE_ERROR` if model exist when creating

pkg/service/service.go

@@ -347,7 +347,7 @@ func (s *service) TriggerUserModelTestMode(ctx context.Context, modelUID uuid.UU
 func (s *service) CheckModel(ctx context.Context, modelUID uuid.UUID) (*modelPB.Model_State, error) {
 	inferenceModel, err := s.repository.GetInferenceEnsembleModel(modelUID)
 	if err != nil {
-		return nil, status.Errorf(codes.NotFound, "ray model not found")
+		return nil, status.Errorf(codes.NotFound, "model not found")
 	}
 
 	inferenceModelName := inferenceModel.Name
@@ -381,7 +381,7 @@ func (s *service) TriggerUserModel(ctx context.Context, modelUID uuid.UUID, infe
 
 	inferenceModel, err := s.repository.GetInferenceEnsembleModel(modelUID)
 	if err != nil {
-		return nil, status.Errorf(codes.NotFound, "triton model not found")
+		return nil, status.Errorf(codes.NotFound, "model not found")
 	}
 
 	inferenceModelName := inferenceModel.Name

pkg/worker/model.go

@@ -14,6 +14,8 @@ import (
 	"go.temporal.io/sdk/activity"
 	"go.temporal.io/sdk/temporal"
 	"go.temporal.io/sdk/workflow"
+	"google.golang.org/grpc/codes"
+	"google.golang.org/grpc/status"
 
 	"github.com/instill-ai/model-backend/config"
 	"github.com/instill-ai/model-backend/pkg/datamodel"
@@ -247,7 +249,14 @@ func (w *worker) CreateModelWorkflow(ctx workflow.Context, param *ModelParams) e
 	logger.Info("CreateModelWorkflow started")
 
 	if err := w.repository.CreateUserModel(param.Model); err != nil {
-		return err
+		if e, ok := status.FromError(err); ok {
+			if e.Code() != codes.AlreadyExists {
+				return err
+			} else {
+				logger.Info("Model already existed, CreateModelWorkflow completed")
+				return nil
+			}
+		}
 	}
 
 	logger.Info("CreateModelWorkflow completed")