|
@@ -386,7 +386,7 @@ def run_theta_rho_file(file_path, schedule_hours=None):
|
|
|
# Update execution progress with formatted ETA
|
|
# Update execution progress with formatted ETA
|
|
|
execution_progress = (i + batch_size, total_coordinates, estimated_remaining_time)
|
|
execution_progress = (i + batch_size, total_coordinates, estimated_remaining_time)
|
|
|
break
|
|
break
|
|
|
- elif response.startswith("IGNORE"): # Retry the previous batch
|
|
|
|
|
|
|
+ elif response.startswith("IGNORE") and i != 0: # Retry the previous batch
|
|
|
print("Received IGNORE. Resending the previous batch...")
|
|
print("Received IGNORE. Resending the previous batch...")
|
|
|
# Calculate the previous batch indices
|
|
# Calculate the previous batch indices
|
|
|
prev_start = max(0, i - batch_size) # Ensure we don't go below 0
|
|
prev_start = max(0, i - batch_size) # Ensure we don't go below 0
|