Skip to content

Commit 434dd92

Browse files
Revert "fix: Update milvus connect function to work with remote instance" (feast-dev#5398)
Revert "fix: Update milvus connect function to work with remote instance (feast-dev#5382)" This reverts commit 7e5e7d5.
1 parent c99905d commit 434dd92

File tree

1 file changed

+3
-6
lines changed
  • sdk/python/feast/infra/online_stores/milvus_online_store

1 file changed

+3
-6
lines changed

sdk/python/feast/infra/online_stores/milvus_online_store/milvus.py

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ class MilvusOnlineStoreConfig(FeastConfigBaseModel, VectorStoreConfig):
8888
"""
8989

9090
type: Literal["milvus"] = "milvus"
91-
path: Optional[StrictStr] = ""
91+
path: Optional[StrictStr] = "online_store.db"
9292
host: Optional[StrictStr] = "localhost"
9393
port: Optional[int] = 19530
9494
index_type: Optional[str] = "FLAT"
@@ -126,16 +126,13 @@ def _get_db_path(self, config: RepoConfig) -> str:
126126

127127
def _connect(self, config: RepoConfig) -> MilvusClient:
128128
if not self.client:
129-
if config.provider == "local" and config.online_store.path:
129+
if config.provider == "local":
130130
db_path = self._get_db_path(config)
131131
print(f"Connecting to Milvus in local mode using {db_path}")
132132
self.client = MilvusClient(db_path)
133133
else:
134-
print(
135-
f"Connecting to Milvus remotely at {config.online_store.host}:{config.online_store.port}"
136-
)
137134
self.client = MilvusClient(
138-
uri=f"{config.online_store.host}:{config.online_store.port}",
135+
url=f"{config.online_store.host}:{config.online_store.port}",
139136
token=f"{config.online_store.username}:{config.online_store.password}"
140137
if config.online_store.username and config.online_store.password
141138
else "",

0 commit comments

Comments
 (0)