5e80af5718813e29a81c036d862c355deb7e70d5,qanta/guesser/elasticsearch.py,ElasticSearchGuesser,guess,#ElasticSearchGuesser#Any#Any#,25

Before Change

              max_n_guesses: Optional[int]):
        predictions = []
        es_index = ElasticSearchIndex()
        bar = progressbar.ProgressBar()
        for q in bar(questions):
            guesses = es_index.search(q)[:max_n_guesses]
            predictions.append(guesses)
        return predictions

After Change

              questions: List[QuestionText],
              max_n_guesses: Optional[int]):
        predictions = []
        pool = Pool(processes=conf["guessers"]["ElasticSearch"]["n_cores"])
        for guesses in pool.starmap(es_search,
                                    zip(repeat(max_n_guesses), questions), chunksize=1000):
            predictions.append(guesses)

Instances