[gce]: DeleteInstances 409 case

continue on 409s as the operation already exists
kubernetes · Sep 15, 2022 · f5e6fea · f5e6fea
1 parent b042aae
commit f5e6fea
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/cluster-autoscaler/cloudprovider/gce/autoscaling_gce_client.go b/cluster-autoscaler/cloudprovider/gce/autoscaling_gce_client.go
@@ -259,7 +259,8 @@ func (client *autoscalingGceClientV1) DeleteInstances(migRef GceRef, instances [
 		req.Instances = append(req.Instances, GenerateInstanceUrl(i))
 	}
 	op, err := client.gceService.InstanceGroupManagers.DeleteInstances(migRef.Project, migRef.Zone, migRef.Name, &req).Do()
-	if err != nil {
+	wasConflictErr := op != nil && op.HttpErrorStatusCode == http.StatusConflict
+	if !wasConflictErr && err != nil {
 		return err
 	}
 	return client.waitForOp(op, migRef.Project, migRef.Zone, true)