From 3e386fb41d4b901fece19f387332b057844eeb29 Mon Sep 17 00:00:00 2001 From: Soam Vasani Date: Fri, 6 Jan 2017 22:09:17 -0800 Subject: [PATCH] Handle pod cleanup on svc creation error --- poolmgr/gp.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/poolmgr/gp.go b/poolmgr/gp.go index 820cc941..8264f7aa 100644 --- a/poolmgr/gp.go +++ b/poolmgr/gp.go @@ -435,9 +435,11 @@ func (gp *GenericPool) GetFuncSvc(m *fission.Metadata) (*funcSvc, error) { labels := gp.labelsForMetadata(m) svc, err := gp.createSvc(svcName, labels) if err != nil { + gp.scheduleDeletePod(pod.ObjectMeta.Name) return nil, err } if svc.ObjectMeta.Name != svcName { + gp.scheduleDeletePod(pod.ObjectMeta.Name) return nil, errors.New(fmt.Sprintf("sanity check failed for svc %v", svc.ObjectMeta.Name)) }