Method hasValidProvisioner

coderd/autobuild/lifecycle_executor.go:139–168

hasValidProvisioner checks whether there is at least one valid (non-stale, correct tags) provisioner based on time t and the tags maps (such as from a templateVersionJob).

(ctx context.Context, tx database.Store, t time.Time, ws database.Workspace, tags map[string]string)

// hasValidProvisioner checks whether there is at least one valid (non-stale, correct tags) provisioner
// based on time t and the tags maps (such as from a templateVersionJob).
func (e *Executor) hasValidProvisioner(ctx context.Context, tx database.Store, t time.Time, ws database.Workspace, tags map[string]string) (bool, error) {
	queryParams := database.GetProvisionerDaemonsByOrganizationParams{
		OrganizationID: ws.OrganizationID,
		WantTags:       tags,
	}

	// nolint: gocritic // The user (in this case, the user/context for autostart builds) may not have the full
	// permissions to read provisioner daemons, but we need to check if there's any for the job prior to the
	// execution of the job via autostart to fix: https://github.com/coder/coder/issues/17941
	provisionerDaemons, err := tx.GetProvisionerDaemonsByOrganization(dbauthz.AsSystemReadProvisionerDaemons(ctx), queryParams)
	if err != nil {
		return false, xerrors.Errorf("get provisioner daemons: %w", err)
	}

	logger := e.log.With(slog.F("tags", tags))
	// Check if any provisioners are active (not stale)
	for _, pd := range provisionerDaemons {
		if pd.LastSeenAt.Valid {
			age := t.Sub(pd.LastSeenAt.Time)
			if age <= provisionerdserver.StaleInterval {
				logger.Debug(ctx, "hasValidProvisioner: found active provisioner",
					slog.F("daemon_id", pd.ID),
				)
				return true, nil
			}
		}
	}
	logger.Debug(ctx, "hasValidProvisioner: no active provisioners found")
	return false, nil
}

func (e *Executor) runOnce(t time.Time) Stats {
	stats := Stats{