|
@@ -60,18 +60,14 @@ export class MilvusService {
|
|
|
|
|
|
// don't break attu
|
|
// don't break attu
|
|
await milvusClient.connectPromise.catch(error => {
|
|
await milvusClient.connectPromise.catch(error => {
|
|
- cache.dump();
|
|
|
|
throw HttpErrors(HTTP_STATUS_CODE.FORBIDDEN, error);
|
|
throw HttpErrors(HTTP_STATUS_CODE.FORBIDDEN, error);
|
|
});
|
|
});
|
|
|
|
|
|
// check healthy
|
|
// check healthy
|
|
const res = await milvusClient.checkHealth();
|
|
const res = await milvusClient.checkHealth();
|
|
|
|
|
|
- console.log('res', milvusAddress, res);
|
|
|
|
-
|
|
|
|
if (res.isHealthy) {
|
|
if (res.isHealthy) {
|
|
MilvusService.activeAddress = address;
|
|
MilvusService.activeAddress = address;
|
|
- cache.dump();
|
|
|
|
cache.set(address, milvusClient);
|
|
cache.set(address, milvusClient);
|
|
return { address };
|
|
return { address };
|
|
} else {
|
|
} else {
|