server/msplanner.py
changeset 5989 099d46422f5a
parent 5943 f1abba8ccc01
child 6027 f91b72def783
equal deleted inserted replaced
5988:d8ac8acd27f9 5989:099d46422f5a
  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)
       
  1159                 if temptable:
  1158                 if temptable:
  1160                     steps.append(FetchStep(plan, sunion, sources, temptable, True, inputmap))
  1159                     steps.append(FetchStep(plan, sunion, sources, temptable, True, inputmap))
  1161                 else:
  1160                 else:
  1162                     steps.append(OneFetchStep(plan, sunion, sources, inputmap))
  1161                     steps.append(OneFetchStep(plan, sunion, sources, inputmap))
  1163         # then add steps for splitted query parts
  1162         # then add steps for splitted query parts