diff --git a/api/controllers/console/datasets/datasets_document.py b/api/controllers/console/datasets/datasets_document.py index 21ede0e238..6a0b63097c 100644 --- a/api/controllers/console/datasets/datasets_document.py +++ b/api/controllers/console/datasets/datasets_document.py @@ -1432,7 +1432,7 @@ class DocumentGenerateSummaryApi(Resource): continue # Dispatch async task - generate_summary_index_task(dataset_id, document.id) + generate_summary_index_task.delay(dataset_id, document.id) logger.info( "Dispatched summary generation task for document %s in dataset %s", document.id, diff --git a/api/tasks/regenerate_summary_index_task.py b/api/tasks/regenerate_summary_index_task.py index db6e6f854e..2c688652d2 100644 --- a/api/tasks/regenerate_summary_index_task.py +++ b/api/tasks/regenerate_summary_index_task.py @@ -6,7 +6,7 @@ from collections import defaultdict import click from celery import shared_task -from sqlalchemy import and_, or_, select +from sqlalchemy import or_, select from extensions.ext_database import db from models.dataset import Dataset, DocumentSegment, DocumentSegmentSummary