Method run

server/build_queue.go:129–187

(task *BuildTask)

}

func (q *BuildQueue) run(task *BuildTask) {
	var output BuildOutput

	defer func() {
		if r := recover(); r != nil {
			output.err = fmt.Errorf("build panic: %v", r)
			task.ctx.status = "error"
			task.ctx.logger.Errorf("build '%s' panicked: %v", task.ctx.Path(), r)
		}

		waitChans := task.waitChans

		q.lock.Lock()
		q.chann++
		delete(q.queue, task)
		delete(q.tasks, task.ctx.Path())
		if task.ctx.rawPath != "" {
			// the `Build` function may have changed the path
			delete(q.tasks, task.ctx.rawPath)
		}
		q.startSchedulerLocked()
		q.lock.Unlock()

		for _, ch := range waitChans {
			if ch == nil {
				continue
			}
			select {
			case ch <- output:
			default:
				// the request may have already timed out while waiting on the build
			}
		}
	}()

	buildTimeout := 10 * time.Minute
	if config != nil && config.BuildTimeout > 0 {
		buildTimeout = time.Duration(config.BuildTimeout) * time.Second
	}
	buildCtx, cancel := context.WithTimeout(context.Background(), buildTimeout)
	defer cancel()

	meta, err := task.ctx.Build(buildCtx)
	if errors.Is(err, context.DeadlineExceeded) {
		err = fmt.Errorf("build timeout after %d seconds", buildTimeout/time.Second)
	}
	if err == nil {
		task.ctx.status = "done"
		if task.ctx.target == "types" {
			task.ctx.logger.Infof("build '%s'(types) done in %v", task.ctx.Path(), time.Since(task.startedAt))
		} else {
			task.ctx.logger.Infof("build '%s' done in %v", task.ctx.Path(), time.Since(task.startedAt))
		}
	} else {
		task.ctx.status = "error"
		task.ctx.logger.Errorf("build '%s': %v", task.ctx.Path(), err)
	}
	output = BuildOutput{meta: meta, err: err}