diff --git a/index/upside_down/upside_down.go b/index/upside_down/upside_down.go index f11c21d6..72182249 100644 --- a/index/upside_down/upside_down.go +++ b/index/upside_down/upside_down.go @@ -265,9 +265,7 @@ func (udc *UpsideDownCouch) Update(doc *document.Document) (err error) { resultChan := make(chan *index.AnalysisResult) aw := index.NewAnalysisWork(udc, doc, resultChan) // put the work on the queue - go func() { - udc.analysisQueue.Queue(aw) - }() + udc.analysisQueue.Queue(aw) // wait for the result result := <-resultChan