Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 1 addition & 3 deletions backend/app/routers/data.py
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,6 @@
BOOK_IMPORT_FIELDS,
PREDEFINED_MAPPINGS,
compute_schema_fingerprint,
delete_parsed_upload,
execute_import,
get_predefined_mapping,
load_parsed_upload,
Expand Down Expand Up @@ -323,8 +322,7 @@ async def event_generator():
final_error = 'error.importExecutionFailed'
yield f"data: {json.dumps({'event': 'error', 'message': 'error.importExecutionFailed'})}\n\n"
finally:
if completed and import_failed_rows == 0 and final_error is None:
delete_parsed_upload(body.file_id, current_user.id)
pass # import file is cleaned up by the periodic temp file job

return StreamingResponse(
event_generator(),
Expand Down
4 changes: 2 additions & 2 deletions backend/app/services/data_import.py
Original file line number Diff line number Diff line change
Expand Up @@ -838,7 +838,7 @@ async def execute_import(
"tags": {"source": "Bookshelves", "transform": None},
"notes": {
"source": "My Review",
"transform": "value.replace('<br/>', '\n') if value else None",
"transform": "re.sub(r'<br\\s*/?>', '\\n', value, flags=re.IGNORECASE) if value else None",
},
"blurb": {"source": "", "transform": None},
"rating": {
Expand Down Expand Up @@ -885,7 +885,7 @@ def get_predefined_mapping(mapping_id: int) -> dict[str, object] | None:
return None


def cleanup_temp_files(max_age_hours: int = 24) -> None:
def cleanup_temp_files(max_age_hours: int = 48) -> None:
"""Delete temporary import files older than *max_age_hours*.

Args:
Expand Down
Loading