diff --git a/task/summary3.py b/task/summary3.py index 05481e7..38e9062 100644 --- a/task/summary3.py +++ b/task/summary3.py @@ -182,7 +182,7 @@ class Summary3(Task): projection = self.Model.get_fields() user_df = pd.DataFrame(self.local_db[self.source_coll].find(where, projection)) - # self.handler_summary(user_df, ts['cursor_st']) + self.handler_summary(user_df, ts['cursor_st']) if self.is_inc: self.handler_summary_inc(ts['cursor_st'])