Function ListIncompleteTask

cmd/cql-proxy/model/task.go:259–267

ListIncompleteTask fetches incomplete task for scheduling with limits.

(db *gorp.DbMap, limit int64)

// ListIncompleteTask fetches incomplete task for scheduling with limits.
func ListIncompleteTask(db *gorp.DbMap, limit int64) (tasks []*Task, err error) {
	_, err = db.Select(&tasks,
		`SELECT * FROM "task" WHERE "state" NOT IN (?, ?) ORDER BY "id" ASC LIMIT ?`,
		TaskSuccess, TaskFailed, limit)
	if err != nil {
		err = errors.Wrapf(err, "get incomplete task list failed")
	}
	return
}