equal
deleted
inserted
replaced
342 results |
342 results |
343 """ |
343 """ |
344 def __init__(self, plan, union): |
344 def __init__(self, plan, union): |
345 Step.__init__(self, plan) |
345 Step.__init__(self, plan) |
346 self.union = union |
346 self.union = union |
|
347 self.rql_query_tracing_token = None |
347 |
348 |
348 def execute(self): |
349 def execute(self): |
349 """call .syntax_tree_search with the given syntax tree on each |
350 """call .syntax_tree_search with the given syntax tree on each |
350 source for each solution |
351 source for each solution |
351 """ |
352 """ |
363 cachekey = tuple(cachekey) |
364 cachekey = tuple(cachekey) |
364 else: |
365 else: |
365 cachekey = union.as_string() |
366 cachekey = union.as_string() |
366 # get results for query |
367 # get results for query |
367 source = cnx.repo.system_source |
368 source = cnx.repo.system_source |
368 result = source.syntax_tree_search(cnx, union, args, cachekey) |
369 result = source.syntax_tree_search(cnx, union, args, cachekey, |
|
370 rql_query_tracing_token=self.rql_query_tracing_token) |
369 return result |
371 return result |
370 |
372 |
371 def mytest_repr(self): |
373 def mytest_repr(self): |
372 """return a representation of this step suitable for test""" |
374 """return a representation of this step suitable for test""" |
373 return (self.__class__.__name__, |
375 return (self.__class__.__name__, |