disallow undeploy and redeploy if version endpoint is pending deployemnt

Author: vinoth-gojek

api/api/version_endpoints_api.go

@@ -205,6 +205,10 @@ func (c *EndpointsController) UpdateEndpoint(r *http.Request, vars map[string]st
 		return InternalServerError(fmt.Sprintf("Error getting endpoint: %v", err))
 	}
 
+	if endpoint.IsPending() {
+		return BadRequest(fmt.Sprintf("Version Endpoint %s is still pending and cannot be redeployed", endpointID))
+	}
+
 	newEndpoint, ok := body.(*models.VersionEndpoint)
 	if !ok {
 		return BadRequest("Unable to parse body as version endpoint resource")
@@ -313,6 +317,10 @@ func (c *EndpointsController) DeleteEndpoint(r *http.Request, vars map[string]st
 		return BadRequest(fmt.Sprintf("Version Endpoints %s is still serving traffic. Please route the traffic to another model version first", rawEndpointID))
 	}
 
+	if endpoint.IsPending() {
+		return BadRequest(fmt.Sprintf("Version Endpoint %s is still pending and cannot be undeployed", rawEndpointID))
+	}
+
 	_, err = c.EndpointsService.UndeployEndpoint(ctx, env, model, version, endpoint)
 	if err != nil {
 		return InternalServerError(fmt.Sprintf("Unable to undeploy version endpoint %s: %v", rawEndpointID, err))

api/models/version_endpoint.go

@@ -15,6 +15,7 @@
 package models
 
 import (
+	"fmt"
 	"net/url"
 	"time"
 
@@ -133,6 +134,11 @@ func (ve *VersionEndpoint) IsServing() bool {
 	return ve.Status == EndpointServing
 }
 
+func (ve *VersionEndpoint) IsPending() bool {
+	fmt.Println("status of the version endpoint is", ve.Status)
+	return ve.Status == EndpointPending
+}
+
 func (ve *VersionEndpoint) IsModelMonitoringEnabled() bool {
 	if ve.ModelObservability == nil {
 		return ve.EnableModelObservability