diff --git a/milvus_client.py b/milvus_client.py
index f9a3794..f551255 100644
--- a/milvus_client.py
+++ b/milvus_client.py
@@ -54,6 +54,10 @@ class MilvusClient(PyOperator):
         else:
             self._connection_args['secure'] = True
 
+        self._connection_args['user'] = user
+        self._connection_args['password'] = password
+        self._connection_args['token'] = token
+
         connections.connect(**self._connection_args)