166cb2c804d081401f0efb52745d214fa633fae1,qanta/guesser/elasticsearch.py,ElasticSearchGuesser,guess,#ElasticSearchGuesser#Any#Any#,38

Before Change

    def guess(self,
              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)

After Change

        def es_search(query):
            return es_index.search(query)[:max_n_guesses]

        return sc.parallelize(questions, 4 * n_cores).map(es_search).collect()

    @classmethod
    def targets(cls):
        return []

Instances