server/msplanner.py
changeset 5943 f1abba8ccc01
parent 5768 1e73a466aa69
child 5989 099d46422f5a
equal deleted inserted replaced
5941:f6c890ad4fd4 5943:f1abba8ccc01
  1153             for inputmap, queries in byinputmap.iteritems():
  1153             for inputmap, queries in byinputmap.iteritems():
  1154                 inputmap = dict(inputmap)
  1154                 inputmap = dict(inputmap)
  1155                 sunion = Union()
  1155                 sunion = Union()
  1156                 for select in queries:
  1156                 for select in queries:
  1157                     sunion.append(select)
  1157                     sunion.append(select)
       
  1158                     self.rqlhelper.annotate(select)
  1158                 if temptable:
  1159                 if temptable:
  1159                     steps.append(FetchStep(plan, sunion, sources, temptable, True, inputmap))
  1160                     steps.append(FetchStep(plan, sunion, sources, temptable, True, inputmap))
  1160                 else:
  1161                 else:
  1161                     steps.append(OneFetchStep(plan, sunion, sources, inputmap))
  1162                     steps.append(OneFetchStep(plan, sunion, sources, inputmap))
  1162         # then add steps for splitted query parts
  1163         # then add steps for splitted query parts