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
}