Skip to content
Snippets Groups Projects
Commit 8c550fbe authored by Tucker Gary Siegel's avatar Tucker Gary Siegel
Browse files

drop so it doesnt freak out anymore

parent a92026f8
No related branches found
No related tags found
No related merge requests found
...@@ -346,18 +346,22 @@ func CalculateStages(ctx common.DawnCtx, request models.StageRequest) map[string ...@@ -346,18 +346,22 @@ func CalculateStages(ctx common.DawnCtx, request models.StageRequest) map[string
} }
stageMatches := models.BuildStageMatches(request.Mode, request.Value) stageMatches := models.BuildStageMatches(request.Mode, request.Value)
comparisonThread := dispatch.New[map[string]time.Time]() // removing for now
go comparisonGoRoutine(gddReq, request.PlantDate, stageMatches, request.Comparison, comparisonThread) // 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) out := forecast(ctx, gddReq, request.PlantDate, stageMatches, gdds, cfs)
// block, wait for comparison results // // block, wait for comparison results
compResults, compError := comparisonThread.Get() // compResults, compError := comparisonThread.Get()
if compError != nil { // if compError != nil {
panic(compError) // panic(compError)
} // }
compResults := comparisonNormals(gddReq, request.PlantDate, stageMatches)
for k, v := range compResults { for k, v := range compResults {
out[k].ComparisonMean = v out[k].ComparisonMean = v
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment