jyapayne/dify
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix milvus database name parameter missed (#3229)

Browse source
This commit is contained in:
Jyong 2024-04-09 15:54:13 +08:00 • committed by GitHub
commit 8fcf459285
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
api/core/rag/datasource/vdb/milvus/milvus_vector.py
View file

@ -130,7 +130,8 @@ class MilvusVector(BaseVector):
uri = "https://" + str(self._client_config.host) + ":" + str(self._client_config.port) uri = "https://" + str(self._client_config.host) + ":" + str(self._client_config.port)
else: else:
uri = "http://" + str(self._client_config.host) + ":" + str(self._client_config.port) uri = "http://" + str(self._client_config.host) + ":" + str(self._client_config.port)
connections.connect(alias=alias, uri=uri, user=self._client_config.user, password=self._client_config.password) connections.connect(alias=alias, uri=uri, user=self._client_config.user, password=self._client_config.password,
db_name=self._client_config.database)
from pymilvus import utility from pymilvus import utility
if utility.has_collection(self._collection_name, using=alias): if utility.has_collection(self._collection_name, using=alias):
@ -142,7 +143,8 @@ class MilvusVector(BaseVector):
uri = "https://" + str(self._client_config.host) + ":" + str(self._client_config.port) uri = "https://" + str(self._client_config.host) + ":" + str(self._client_config.port)
else: else:
uri = "http://" + str(self._client_config.host) + ":" + str(self._client_config.port) uri = "http://" + str(self._client_config.host) + ":" + str(self._client_config.port)
connections.connect(alias=alias, uri=uri, user=self._client_config.user, password=self._client_config.password) connections.connect(alias=alias, uri=uri, user=self._client_config.user, password=self._client_config.password,
db_name=self._client_config.database)
from pymilvus import utility from pymilvus import utility
if not utility.has_collection(self._collection_name, using=alias): if not utility.has_collection(self._collection_name, using=alias):