Merge pull request #574 from shankari/create_tree_pipeline

Actually use the current time range for querying sections

emission/analysis/classification/inference/mode/pipeline.py

@@ -126,7 +126,7 @@ def getLastSectionDone(self):
   def runPredictionPipeline(self, user_id, timerange):
     self.ts = esta.TimeSeries.get_time_series(user_id)
     self.toPredictSections = esda.get_entries(esda.CLEANED_SECTION_KEY, user_id, 
-        time_query=None)
+        time_query=timerange)
     if (len(self.toPredictSections) == 0):
         logging.debug("len(toPredictSections) == 0, early return")
         assert self.last_section_done is None, ("self.last_section_done == %s, expecting None" % \