def get_es(self, default_builder=get_es):
        # .es() calls are incremental, so we go through them all and
        # update bits that are specified.
        args = {}
        for action, value in self.steps:
            if action == 'es':
                args.update(**value)

        # TODO: store the Elasticsearch on the S if we've already
        # created one since we don't need to do it multiple times.
        return default_builder(**args)
Returns the Elasticsearch object to use.
dataset/ETHPy150Open mozilla/elasticutils/elasticutils/__init__.py/S.get_es