in internal/checkpoint/checkpoint.go [75:86]
func (c *Checkpoint) FetchCurrentStageFromCluster(ctx context.Context) (Stage, error) {
stage := NewStage("")
configMap, err := c.GetConfigMap(ctx)
if err != nil {
return stage, err
}
stage, err = GetStageStringValueFromConfigMap(&configMap)
if err != nil {
return stage, err
}
return stage, nil
}