equal
deleted
inserted
replaced
510 |
510 |
511 def process(self, rql, args=None): |
511 def process(self, rql, args=None): |
512 if args is None: |
512 if args is None: |
513 args = {} |
513 args = {} |
514 querier = self.repo.querier |
514 querier = self.repo.querier |
515 union = querier.parse(rql) |
515 union = parse(rql) # self.vreg.parse(rql, annotate=True) |
516 with self.admin_access.repo_cnx() as cnx: |
516 with self.admin_access.repo_cnx() as cnx: |
517 querier.solutions(cnx, union, args) |
517 self.vreg.solutions(cnx, union, args) |
518 querier._annotate(union) |
518 querier._annotate(union) |
519 plan = querier.plan_factory(union, args, cnx) |
519 plan = querier.plan_factory(union, args, cnx) |
520 plan.preprocess(union) |
520 plan.preprocess(union) |
521 return union |
521 return union |
522 |
522 |