gyt/opendan
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

modify knowledge email source

Browse Source
This commit is contained in:
tsukasa
2023-09-26 16:39:14 +08:00
parent cf2d917404
commit f472689ecb
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/aios_kernel/knowledge_pipeline.py
+8 -8
View File
@@ -158,14 +158,14 @@ class KnowledgeEmailSource:
_uid = int.from_bytes(uid) _uid = int.from_bytes(uid)
if _uid > latest_uid: if _uid > latest_uid:
email_dir = self.check_email_saved(uid) email_dir = self.check_email_saved(uid)
if email_dir is not None: if email_dir is not None:
logging.info(f"email uid {uid} already saved") logging.info(f"email uid {uid} already saved")
else: else:
email_dir = self.read_and_save_email(uid) email_dir = self.read_and_save_email(uid)
logging.info(f"email uid {uid} saved") logging.info(f"email uid {uid} saved")
email_object = EmailObjectBuilder({}, email_dir).build() email_object = EmailObjectBuilder({}, email_dir).build()
await KnowledgeBase().insert_object(email_object) await KnowledgeBase().insert_object(email_object)
journal_client.insert(KnowledgeJournal("email", self.id(), str(int.from_bytes(uid)), str(email_object.calculate_id()))) journal_client.insert(KnowledgeJournal("email", self.id(), str(int.from_bytes(uid)), str(email_object.calculate_id())))
def read_and_save_email(self, uid: str) -> str: def read_and_save_email(self, uid: str) -> str: