diff --git a/task/summary_func.py b/task/summary_func.py index 73e491e..4b35204 100644 --- a/task/summary_func.py +++ b/task/summary_func.py @@ -43,7 +43,7 @@ class SummaryFunc(Task): data = model.dict() bulk_data.append(UpdateOne({'_id': data['_id']}, {'$set': data}, upsert=True)) except Exception as e: - # logger.error(f'ftype {item["ftype"]} msg:{e}') - pass + logger.error(f'ftype {item["ftype"]} msg:{e}') + # pass self.remote_db[self.task_name].bulk_write(bulk_data, ordered=False) self.set_cursor(cursor_st=ts['cursor_st'], cursor_et=ts['cursor_et'])