handle race condition where resource has already been created after t…

…he exists check (#11) Signed-off-by: Scott Weiss <[email protected]>
solo-io · Nov 27, 2018 · 72a27ce · 72a27ce
1 parent 596f6d9
commit 72a27ce
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/api/v1/clients/kube/resource_client.go b/pkg/api/v1/clients/kube/resource_client.go
@@ -276,6 +276,9 @@ func (rc *ResourceClient) Write(resource resources.Resource, opts clients.WriteO
 		stats.Record(ctx, MCreates.M(1), MInFlight.M(1))
 		defer stats.Record(ctx, MInFlight.M(-1))
 		if _, err := rc.kube.ResourcesV1().Resources(meta.Namespace).Create(resourceCrd); err != nil {
+			if apierrors.IsAlreadyExists(err) {
+				return nil, errors.NewExistErr(meta)
+			}
 			return nil, errors.Wrapf(err, "creating kube resource %v", resourceCrd.Name)
 		}
 	}