diff --git a/private_gpt/celery/tasks/ingestion/extraction_tasks.py b/private_gpt/celery/tasks/ingestion/extraction_tasks.py index d7781c74..786d7834 100644 --- a/private_gpt/celery/tasks/ingestion/extraction_tasks.py +++ b/private_gpt/celery/tasks/ingestion/extraction_tasks.py @@ -103,7 +103,6 @@ def vector_index_task(body: IngestAsyncBody) -> Any: ) service = get_global_injector().get(IngestService) - content = body.ingest_body.input.to_binary_content( filename=get_file_name(body.ingest_body.metadata) ) diff --git a/private_gpt/components/ingestion/ingestion_scheduler.py b/private_gpt/components/ingestion/ingestion_scheduler.py index c52df222..d648e1fc 100644 --- a/private_gpt/components/ingestion/ingestion_scheduler.py +++ b/private_gpt/components/ingestion/ingestion_scheduler.py @@ -130,7 +130,6 @@ class CeleryIngestionScheduler(BaseIngestionScheduler): collection=ingest_body.ingest_body.collection, artifact=ingest_body.ingest_body.artifact, ) - if ingest_body.ingest_body.input: should_upload = ( not isinstance(ingest_body.ingest_body.input, UriArtifact)