Nail/fission-src
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Handle pod cleanup on svc creation error

Browse Source
This commit is contained in:
Soam Vasani
2017-01-06 22:09:17 -08:00
parent e4f7027a69
commit 3e386fb41d
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
poolmgr/gp.go
+2
View File
@@ -435,9 +435,11 @@ func (gp *GenericPool) GetFuncSvc(m *fission.Metadata) (*funcSvc, error) {
labels := gp.labelsForMetadata(m) labels := gp.labelsForMetadata(m)
svc, err := gp.createSvc(svcName, labels) svc, err := gp.createSvc(svcName, labels)
if err != nil { if err != nil {
gp.scheduleDeletePod(pod.ObjectMeta.Name)
return nil, err return nil, err
} }
if svc.ObjectMeta.Name != svcName { 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)) return nil, errors.New(fmt.Sprintf("sanity check failed for svc %v", svc.ObjectMeta.Name))
} }