mirror of
https://github.com/Hestia-Homes/Model.git
synced 2026-06-08 11:17:27 +00:00
remove combined as i'm doing that later
This commit is contained in:
parent
33d355e2c3
commit
574156b403
1 changed files with 0 additions and 28 deletions
|
|
@ -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,
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue