Searched refs:PARALLEL_SHARDS (Results 1 – 1 of 1) sorted by relevance
84 PARALLEL_SHARDS = False variable493 if PARALLEL_SHARDS and PARALLEL_SHARDS > 1:494 logger.debug("spawning %i query processes", PARALLEL_SHARDS)495 pool = multiprocessing.Pool(PARALLEL_SHARDS)496 result = pool.imap(query_shard, args, chunksize=1 + len(self.shards) / PARALLEL_SHARDS)