Method triggerDeploymentReconcileJob

admin/deployments.go:729–741

triggerDeploymentReconcileJob triggers a reconcile deployment job for the given deployment ID. For more details, see the comments in the ReconcileDeployment job.

(ctx context.Context, deploymentID string)

// triggerDeploymentReconcileJob triggers a reconcile deployment job for the given deployment ID.
// For more details, see the comments in the ReconcileDeployment job.
func (s *Service) triggerDeploymentReconcileJob(ctx context.Context, deploymentID string) error {
	// Trigger reconcile deployment job
	_, err := s.Jobs.ReconcileDeployment(ctx, deploymentID)
	if err != nil {
		// If the job fails to be added, we update the deployment status to error.
		ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
		defer cancel()
		_, err2 := s.DB.UpdateDeploymentStatus(ctx, deploymentID, database.DeploymentStatusErrored, fmt.Sprintf("Failed to Trigger reconcile deployment job: %v", err))
		s.Logger.Error("failed to schedule reconcile deployment job", zap.String("deployment_id", deploymentID), zap.Error(err), observability.ZapCtx(ctx))
		return errors.Join(err, err2)
	}
	return nil
}

func (s *Service) provisionRuntime(ctx context.Context, opts *provisionRuntimeOptions) (*database.ProvisionerResource, error) {
	// Use default if no provisioner is specified.