From 574156b403919f2a81309d6bf1966003f9a1a174 Mon Sep 17 00:00:00 2001 From: Jun-te Kim Date: Mon, 20 Apr 2026 16:38:20 +0000 Subject: [PATCH] remove combined as i'm doing that later --- backend/app/bulk_uploads/router.py | 28 ---------------------------- 1 file changed, 28 deletions(-) diff --git a/backend/app/bulk_uploads/router.py b/backend/app/bulk_uploads/router.py index d9c38250..ca1e7b79 100644 --- a/backend/app/bulk_uploads/router.py +++ b/backend/app/bulk_uploads/router.py @@ -37,31 +37,3 @@ async def trigger_postcode_splitter(req: PostcodeSplitterTriggerRequest): "sqs_message_id": response.get("MessageId"), } - -@router.get("/{task_id}/combined-results") -async def get_combined_results( - task_id: UUID, - offset: int = Query(default=0, ge=0), - limit: int = Query(default=500, ge=1, le=5000), -): - with get_db_session() as session: - upload = session.exec( - select(BulkAddressUpload).where(BulkAddressUpload.task_id == task_id) - ).first() - - if not upload: - raise HTTPException(status_code=404, detail="Upload not found") - - if not upload.combined_output_s3_uri: - raise HTTPException(status_code=409, detail="Combiner not finished") - - bucket, key = parse_s3_uri(upload.combined_output_s3_uri) - rows = read_csv_from_s3(bucket, key) - - total = len(rows) - return { - "rows": rows[offset : offset + limit], - "total": total, - "offset": offset, - "limit": limit, - }