We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4fa4638 commit f90aff9Copy full SHA for f90aff9
src/odoo_data_flow/import_threaded.py
@@ -1184,7 +1184,6 @@ def _execute_load_batch( # noqa: C901
1184
)
1185
1186
if is_scalable_error and chunk_size > 1:
1187
- original_chunk_size = chunk_size
1188
chunk_size = max(1, chunk_size // 2)
1189
progress.console.print(
1190
f"[yellow]WARN:[/] Batch {batch_number} hit scalable error. "
@@ -1237,7 +1236,7 @@ def _execute_load_batch( # noqa: C901
1237
1236
batch_number,
1238
error_message=clean_error,
1239
1240
- lines_to_process = lines_to_process[original_chunk_size:]
+ lines_to_process = lines_to_process[chunk_size:]
1241
serialization_retry_count = 0 # Reset counter for next batch
1242
continue
1243
0 commit comments