From 8c550fbecb50dc9c288a629a39c2dd01c6c76983 Mon Sep 17 00:00:00 2001 From: Tucker Siegel <tgsiegel@terpmail.umd.edu> Date: Thu, 1 Dec 2022 19:10:12 -0500 Subject: [PATCH] drop so it doesnt freak out anymore --- services/forecast_service.go | 20 ++++++++++++-------- 1 file changed, 12 insertions(+), 8 deletions(-) diff --git a/services/forecast_service.go b/services/forecast_service.go index d2771ed..77448c7 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 } -- GitLab