diff --git a/services/forecast_service.go b/services/forecast_service.go index d2771edbced8cd2170feb8eef5d22f685ce02f3c..77448c7dad25334a2ad63f292a268b2b698fd55e 100644 --- a/services/forecast_service.go +++ b/services/forecast_service.go @@ -346,18 +346,22 @@ func CalculateStages(ctx common.DawnCtx, request models.StageRequest) map[string } stageMatches := models.BuildStageMatches(request.Mode, request.Value) - comparisonThread := dispatch.New[map[string]time.Time]() - go comparisonGoRoutine(gddReq, request.PlantDate, stageMatches, request.Comparison, comparisonThread) + // removing for now + // comparisonThread := dispatch.New[map[string]time.Time]() + // go comparisonGoRoutine(gddReq, request.PlantDate, stageMatches, request.Comparison, comparisonThread) + // gdds, cfs := asyncCollectGddsAndCfs(ctx, gddReq) - gdds, cfs := asyncCollectGddsAndCfs(ctx, gddReq) + gdds := GetGddValues(ctx, gddReq) + cfs := persistence.CfsFindByLocationMultiple(gddReq.BuildLocation(), 4) out := forecast(ctx, gddReq, request.PlantDate, stageMatches, gdds, cfs) - // block, wait for comparison results - compResults, compError := comparisonThread.Get() - if compError != nil { - panic(compError) - } + // // block, wait for comparison results + // compResults, compError := comparisonThread.Get() + // if compError != nil { + // panic(compError) + // } + compResults := comparisonNormals(gddReq, request.PlantDate, stageMatches) for k, v := range compResults { out[k].ComparisonMean = v }