func()

in internal/checkpoint/checkpoint.go [61:73]


func (c *Checkpoint) UpdateStageFromConfigMap(ctx context.Context) error {
	stage, err := c.FetchCurrentStageFromCluster(ctx)
	if err != nil {
		if errors.IsNotFound(err) {
			initialStage := getInitialStageFromInstance(c.Instance)
			c.CurrentStage = initialStage
			return nil
		}
		return err
	}
	c.CurrentStage = stage
	return nil
}