@update_trigger
    def index_urls(self, *urls):
        # minimize rpcs by collecting (name, buffer) tuples for
        # different shards up-front
        sharded_input_map = defaultdict(list)
        for url in urls:
            sharded_input_map[self.shard_func(url)].append(url)

        # Issue an indexing call to each sharded backend that has some input
        # Generally the sharded servers should be backed with
        # ConcurrentSimIndexes so that the index_urls() call will generally
        # be non-blocking.
        for shard_id in sharded_input_map:
            self._shards[shard_id].index_urls(
                *sharded_input_map[shard_id]
            )
Index web pages given by urls
dataset/ETHPy150Open taherh/pysimsearch/pysimsearch/sim_index/sim_index_collection.py/SimIndexCollection.index_urls