mirror of
https://github.com/mudler/LocalAI
synced 2026-05-24 09:28:23 +00:00
75fba9e03f
In distributed mode the React UI's "Upgrade All" button fanned every detected outdated backend out to every healthy backend node, including nodes that never had that backend installed. On heterogeneous clusters this surfaced as platform errors (e.g. mac-mini-m4 asked to upgrade cpu-insightface-development, which has no darwin/arm64 variant) and left forever-retrying pending_backend_ops rows. DistributedBackendManager.UpgradeBackend now queries ListBackends() first, builds the target node-ID set from SystemBackend.Nodes, and only fans out to those nodes — every per-node primitive (adapter.InstallBackend, the pending-ops queue, BackendOpResult) is unchanged. enqueueAndDrainBackendOp gains an optional targetNodeIDs allowlist; Install/Delete keep their fan-to-everyone semantics by passing nil. If no node reports the backend installed, UpgradeBackend now returns a clear "not installed on any node" error instead of producing a stuck queue. Adds Ginkgo coverage for the smart fan-out: backend on a subset of nodes goes only to those nodes; backend on no node returns the new error and never sends a NATS install request. Assisted-by: Claude:claude-opus-4-7 [Claude Code] Signed-off-by: Ettore Di Giacinto <mudler@localai.io> |
||
|---|---|---|
| .. | ||
| distributed_store.go | ||
| distributed_store_test.go | ||
| file_stager.go | ||
| file_stager_http.go | ||
| file_stager_s3.go | ||
| file_staging_client.go | ||
| file_transfer_server.go | ||
| file_transfer_server_test.go | ||
| health.go | ||
| health_mock_test.go | ||
| health_test.go | ||
| inflight.go | ||
| inflight_test.go | ||
| interfaces.go | ||
| managers_distributed.go | ||
| managers_distributed_test.go | ||
| model_router.go | ||
| model_router_test.go | ||
| nodes_suite_test.go | ||
| reconciler.go | ||
| reconciler_test.go | ||
| registry.go | ||
| registry_test.go | ||
| router.go | ||
| router_test.go | ||
| staging_keys.go | ||
| staging_keys_test.go | ||
| staging_progress.go | ||
| unloader.go | ||
| unloader_test.go | ||