This commit is contained in:
kf_wuhao 2021-01-08 16:37:12 +08:00
parent cdfc19787e
commit c043eb7aca

View File

@ -182,7 +182,7 @@ class Summary3(Task):
projection = self.Model.get_fields() projection = self.Model.get_fields()
user_df = pd.DataFrame(self.local_db[self.source_coll].find(where, projection)) 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: if self.is_inc:
self.handler_summary_inc(ts['cursor_st']) self.handler_summary_inc(ts['cursor_st'])