func()

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
}