Skip to content

Commit 7eeb42c

Browse files
committed
refactor: replace Status with State for consistent status handling
1 parent 19a1b5a commit 7eeb42c

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

apps/common/event/listener_manage.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,7 @@ def embedding_by_paragraph_list(paragraph_id_list, embedding_model: Embeddings):
9292
@staticmethod
9393
def embedding_by_paragraph_data_list(data_list, paragraph_id_list, embedding_model: Embeddings):
9494
maxkb_logger.info(_('Start--->Embedding paragraph: {paragraph_id_list}').format(paragraph_id_list=paragraph_id_list))
95-
status = Status.success
95+
status = State.SUCCESS
9696
try:
9797
# 删除段落
9898
VectorStore.get_embedding_vector().delete_by_paragraph_ids(paragraph_id_list)
@@ -105,7 +105,7 @@ def is_save_function():
105105
except Exception as e:
106106
maxkb_logger.error(_('Vectorized paragraph: {paragraph_id_list} error {error} {traceback}').format(
107107
paragraph_id_list=paragraph_id_list, error=str(e), traceback=traceback.format_exc()))
108-
status = Status.error
108+
status = State.FAILURE
109109
finally:
110110
QuerySet(Paragraph).filter(id__in=paragraph_id_list).update(**{'status': status})
111111
maxkb_logger.info(

apps/knowledge/task/handler.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
# coding=utf-8
22

33

4-
import logging
54
import re
65
import traceback
76

@@ -11,7 +10,8 @@
1110
from common.utils.fork import ChildLink, Fork
1211
from common.utils.logger import maxkb_logger
1312
from common.utils.split_model import get_split_model
14-
from knowledge.models.knowledge import KnowledgeType, Document, Knowledge, Status
13+
from knowledge.models import State
14+
from knowledge.models.knowledge import KnowledgeType, Document, Knowledge
1515

1616

1717
def get_save_handler(knowledge_id, selector):
@@ -89,7 +89,7 @@ def handler(source_url: str, selector, response: Fork.Response):
8989
meta={'source_url': source_url, 'selector': selector},
9090
type=KnowledgeType.WEB,
9191
char_length=0,
92-
status=Status.error).save()
92+
status=State.FAILURE).save()
9393

9494
return handler
9595

0 commit comments

Comments
 (0)