vumichien commited on
Commit
ec57f71
·
1 Parent(s): 77d18dc

add failed_records

Browse files
Files changed (2) hide show
  1. app.py +5 -1
  2. database.db +0 -0
app.py CHANGED
@@ -428,6 +428,7 @@ async def upload_data_batch(
428
  successful_uploads = 0
429
  failed_uploads = 0
430
  error_messages = []
 
431
 
432
  for record in records.records:
433
  try:
@@ -450,15 +451,17 @@ async def upload_data_batch(
450
  except ValueError as ve:
451
  failed_uploads += 1
452
  error_messages.append(f"Invalid data format: {str(ve)}")
 
453
  except IntegrityError:
454
  db.rollback()
455
  failed_uploads += 1
456
  error_messages.append(f"Duplicate UUID: {record.uuid}")
 
457
  except Exception as e:
458
  db.rollback()
459
  failed_uploads += 1
460
  error_messages.append(f"Error processing record: {str(e)}")
461
-
462
  try:
463
  db.commit()
464
  except Exception as e:
@@ -476,6 +479,7 @@ async def upload_data_batch(
476
  "successful_uploads": successful_uploads,
477
  "failed_uploads": failed_uploads,
478
  "errors": error_messages,
 
479
  },
480
  )
481
 
 
428
  successful_uploads = 0
429
  failed_uploads = 0
430
  error_messages = []
431
+ failed_records = []
432
 
433
  for record in records.records:
434
  try:
 
451
  except ValueError as ve:
452
  failed_uploads += 1
453
  error_messages.append(f"Invalid data format: {str(ve)}")
454
+ failed_records.append(str(uuid_obj))
455
  except IntegrityError:
456
  db.rollback()
457
  failed_uploads += 1
458
  error_messages.append(f"Duplicate UUID: {record.uuid}")
459
+ failed_records.append(str(uuid_obj))
460
  except Exception as e:
461
  db.rollback()
462
  failed_uploads += 1
463
  error_messages.append(f"Error processing record: {str(e)}")
464
+ failed_records.append(str(uuid_obj))
465
  try:
466
  db.commit()
467
  except Exception as e:
 
479
  "successful_uploads": successful_uploads,
480
  "failed_uploads": failed_uploads,
481
  "errors": error_messages,
482
+ "failed_records": failed_records,
483
  },
484
  )
485
 
database.db CHANGED
Binary files a/database.db and b/database.db differ