fix: Replace synchronization error (#1951)
This commit is contained in:
parent
7f9a11dbb8
commit
0f8fb1693a
@ -34,7 +34,7 @@ def sync_web_dataset(dataset_id: str, url: str, selector: str):
|
|||||||
max_kb_error.error(f'同步web知识库:{dataset_id}出现错误{str(e)}{traceback.format_exc()}')
|
max_kb_error.error(f'同步web知识库:{dataset_id}出现错误{str(e)}{traceback.format_exc()}')
|
||||||
|
|
||||||
|
|
||||||
@celery_app.task(base=QueueOnce, once={'keys': ['dataset_id']}, name='celery:sync_web_dataset')
|
@celery_app.task(base=QueueOnce, once={'keys': ['dataset_id']}, name='celery:sync_replace_web_dataset')
|
||||||
def sync_replace_web_dataset(dataset_id: str, url: str, selector: str):
|
def sync_replace_web_dataset(dataset_id: str, url: str, selector: str):
|
||||||
try:
|
try:
|
||||||
max_kb.info(f"开始--->开始同步web知识库:{dataset_id}")
|
max_kb.info(f"开始--->开始同步web知识库:{dataset_id}")
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user