Method CheckProvisionerResource

admin/deployments.go:556–609

(ctx context.Context, pr *database.ProvisionerResource, annotations DeploymentAnnotations)

}

func (s *Service) CheckProvisionerResource(ctx context.Context, pr *database.ProvisionerResource, annotations DeploymentAnnotations) error {
	// Find the provisioner
	p, ok := s.ProvisionerSet[pr.Provisioner]
	if !ok {
		return fmt.Errorf("provisioner: %q is not in the provisioner set", pr.Provisioner)
	}

	// Run a check
	r := &provisioner.Resource{
		ID:     pr.ID,
		Type:   provisioner.ResourceType(pr.Type),
		State:  pr.State,
		Config: pr.Config,
	}
	r, err := p.CheckResource(ctx, r, &provisioner.ResourceOptions{
		Args:        pr.Args,
		Annotations: annotations.ToMap(),
		RillVersion: s.resolveRillVersion(),
	})
	if err != nil {
		// For cancellations, we exit early without updating the status in the DB
		if errors.Is(err, ctx.Err()) {
			return err
		}

		// Set the status as errored
		_, err2 := s.DB.UpdateProvisionerResource(ctx, pr.ID, &database.UpdateProvisionerResourceOptions{
			Status:        database.ProvisionerResourceStatusError,
			StatusMessage: fmt.Sprintf("check failed: %s", err.Error()),
			Args:          pr.Args,
			State:         pr.State,
			Config:        pr.Config,
		})
		if err2 != nil {
			return errors.Join(err, err2)
		}

		return err
	}

	// The returned resource's state may have been updated, so we update the database accordingly.
	_, err = s.DB.UpdateProvisionerResource(ctx, pr.ID, &database.UpdateProvisionerResourceOptions{
		Status:        database.ProvisionerResourceStatusOK,
		StatusMessage: "",
		Args:          pr.Args,
		State:         r.State,
		Config:        r.Config,
	})
	if err != nil {
		return err
	}

	return nil
}

func (s *Service) OpenRuntimeClient(depl *database.Deployment) (*client.Client, error) {
	if depl.RuntimeHost == "" {