diff --git a/milvus_client.py b/milvus_client.py index 47034b7..f9a3794 100644 --- a/milvus_client.py +++ b/milvus_client.py @@ -50,6 +50,8 @@ class MilvusClient(PyOperator): raise ConnectionError('Received invalid connection arguments.') if any(x is None for x in [token, user, password]): + self._connection_args['secure'] = False + else: self._connection_args['secure'] = True connections.connect(**self._connection_args)