Method runQuery

AskAgent/python/core/whoHandler.py:115–140

(self)

    async def runQuery(self):

        try:
            # Send begin-nlweb-response message at the start
            await self.message_sender.send_begin_response()
            tasks = []
            if (ENABLE_QUERY_FANOUT):
                queries = await self.whoQueryRewrite()
            else:
                queries = [self.query]
            for query in queries:
                tasks.append(asyncio.create_task(self.whoRetrieveInt(query)))
            await asyncio.gather(*tasks, return_exceptions=True)

            self.ranker = WhoRanking(self, self.final_retrieved_items)
            await self.ranker.do()

            # Send end-nlweb-response message at the end
            await self.message_sender.send_end_response()

            return [msg.to_dict() for msg in self.messages]

        except Exception:
            # Send end-nlweb-response even on error
            await self.message_sender.send_end_response(error=True)
            raise