Don't send exit event on failure

Signed-off-by: Michael Crosby <crosbymichael@gmail.com>

supervisor/delete.go

@@ -12,6 +12,7 @@ type DeleteTask struct {
 	ID      string
 	Status  int
 	PID     string
+	NoEvent bool
 }
 
 func (s *Supervisor) delete(t *DeleteTask) error {
@@ -20,6 +21,7 @@ func (s *Supervisor) delete(t *DeleteTask) error {
 		if err := s.deleteContainer(i.container); err != nil {
 			logrus.WithField("error", err).Error("containerd: deleting container")
 		}
+		if !t.NoEvent {
 			s.notifySubscribers(Event{
 				Type:      "exit",
 				Timestamp: time.Now(),
@@ -27,6 +29,7 @@ func (s *Supervisor) delete(t *DeleteTask) error {
 				Status:    t.Status,
 				PID:       t.PID,
 			})
+		}
 		ContainersCounter.Dec(1)
 		ContainerDeleteTimer.UpdateSince(start)
 	}

supervisor/worker.go

@@ -47,6 +47,7 @@ func (w *worker) Start() {
 			t.Err <- err
 			evt := &DeleteTask{
 				ID:      t.Container.ID(),
+				NoEvent: true,
 			}
 			w.s.SendTask(evt)
 			continue