From 1a7c213405ac60e60d21a5cf513172a1f238bb3b Mon Sep 17 00:00:00 2001 From: yihong Date: Sun, 15 Dec 2024 17:22:03 +0800 Subject: [PATCH] fix: ExternalDatasetService.process_external_api wrong args (#11586) Signed-off-by: yihong0618 --- api/tasks/external_document_indexing_task.py | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/api/tasks/external_document_indexing_task.py b/api/tasks/external_document_indexing_task.py index 69f3072e2d..a45b3030bf 100644 --- a/api/tasks/external_document_indexing_task.py +++ b/api/tasks/external_document_indexing_task.py @@ -3,7 +3,7 @@ import logging import time import click -from celery import shared_task +from celery import shared_task # type: ignore from core.indexing_runner import DocumentIsPausedError from extensions.ext_database import db @@ -68,11 +68,9 @@ def external_document_indexing_task( settings = ExternalDatasetService.get_external_knowledge_api_settings( json.loads(external_knowledge_api.settings) ) - # assemble headers - headers = ExternalDatasetService.assembling_headers(settings.authorization, settings.headers) # do http request - response = ExternalDatasetService.process_external_api(settings, headers, process_parameter, files) + response = ExternalDatasetService.process_external_api(settings, files) job_id = response.json().get("job_id") if job_id: # save job_id to dataset