Actualizar nodo OmniVision

client.py

@@ -320,7 +320,7 @@ class WorkerEngine:
             started = time.time()
             received = 0
             last_report = started
-            max_attempts = 8
+            max_attempts = 20
 
             # Descarga por HTTP reanudable con Range: si el stream del manager
             # muere a mitad de la transferencia, se reabre la conexión pidiendo
@@ -336,17 +336,17 @@ class WorkerEngine:
 
                     attempt += 1
                     headers = dict(req_headers)
-                    if received > 0 and total_size:
+                    if received > 0:
                         headers["Range"] = f"bytes={received}-"
 
                     try:
                         with self.session.get(download_url, headers=headers, stream=True, timeout=120) as resp:
                             if resp.status_code == 416 and total_size and received >= total_size:
                                 break  # archivo ya completo
-                            if resp.status_code == 200 and received > 0 and total_size:
+                            if resp.status_code == 200 and received > 0:
                                 # El servidor ignoró el Range: reescribir desde cero
                                 f.seek(0)
-                                f.truncate()
+                                f.truncate(0)
                                 received = 0
                             elif resp.status_code == 206 and received > 0:
                                 f.seek(received)
@@ -378,6 +378,7 @@ class WorkerEngine:
                                         chunk = chunk[: total_size - received]
                                     if chunk:
                                         f.write(chunk)
+                                        f.flush()
                                         received += len(chunk)
                                     now = time.time()
                                     if now - last_report >= 1 or (total_size and received >= total_size):