Method cleanupTask

cmd/cql-proxy/task/task.go:310–351

(t *taskItem)

}

func (m *Manager) cleanupTask(t *taskItem) {
	// collect result and save to database
	now := time.Now().Unix()
	t.task.Finished = now
	t.task.Updated = now
	t.task.Result = t.result

	if t.err != nil {
		t.task.State = model.TaskFailed
		t.task.Result = gin.H{
			"error":  t.err.Error(),
			"result": t.task.Result,
		}
	} else {
		t.task.State = model.TaskSuccess
	}

	err := model.UpdateTask(m.db, t.task)
	if err != nil {
		return
	}

	log.Debugf("task cleanup: %v", t.task.LogData())

	// trigger wait
	if waits, ok := m.waitMap[t.task.ID]; ok {
		// trigger waits
		for _, w := range waits {
			if w.ch != nil {
				select {
				case <-w.ch:
				default:
					close(w.ch)
				}
			}
		}

		delete(m.waitMap, t.task.ID)
	}

	delete(m.taskMap, t.task.ID)
}