обновление agent.py

agent.py

@@ -255,21 +255,31 @@ class PublicAddress:
         label = _read("/root/.vast_containerlabel")
         instance_id = label.replace("C.", "").strip()
         if key and instance_id:
-            try:
-                data = http_json("GET", f"{VAST_API}/instances/{instance_id}/",
-                                 headers={"Authorization": f"Bearer {key}"}, timeout=30)[1]
-                inst = data["instances"]
-                self.host = self.host or inst.get("public_ipaddr", "").strip()
-                for spec, binds in (inst.get("ports") or {}).items():
-                    inner = int(spec.split("/")[0])
-                    for b in binds:
-                        if b.get("HostIp") == "0.0.0.0":
-                            self.ports[inner] = int(b["HostPort"])
-                log(f"публичный адрес: {self.host}, проброшено портов: {len(self.ports)}")
-                self._loaded = True
-                return
-            except Exception as e:
-                log(f"Vast API не ответил ({e}), падаю на определение адреса снаружи")
+            # Здесь нельзя откатываться на «внешний ip + тот же порт»: снаружи
+            # порт другой, и нода зарегистрируется по адресу, куда менеджер не
+            # достучится. Лучше долбиться в API, пока не ответит.
+            for attempt in range(1, 11):
+                try:
+                    status, data = http_json("GET", f"{VAST_API}/instances/{instance_id}/",
+                                             headers={"Authorization": f"Bearer {key}"}, timeout=30)
+                    if status != 200:
+                        raise RuntimeError(f"HTTP {status}: {str(data)[:200]}")
+                    inst = data["instances"]
+                    self.host = self.host or inst.get("public_ipaddr", "").strip()
+                    for spec, binds in (inst.get("ports") or {}).items():
+                        inner = int(spec.split("/")[0])
+                        for b in binds:
+                            if b.get("HostIp") == "0.0.0.0":
+                                self.ports[inner] = int(b["HostPort"])
+                    if not self.host or not self.ports:
+                        raise RuntimeError("Vast ещё не отдал адрес и проброс портов")
+                    log(f"публичный адрес: {self.host}, проброшено портов: {len(self.ports)}")
+                    self._loaded = True
+                    return
+                except Exception as e:
+                    log(f"Vast API не ответил (попытка {attempt} из 10): {e}")
+                    time.sleep(15)
+            raise RuntimeError("Vast API так и не отдал проброс портов")
 
         if not self.host:
             try: