diff --git a/airflow/providers/mongo/hooks/mongo.py b/airflow/providers/mongo/hooks/mongo.py index f883a33ad6ac8..857bbc312ff6f 100644 --- a/airflow/providers/mongo/hooks/mongo.py +++ b/airflow/providers/mongo/hooks/mongo.py @@ -37,9 +37,8 @@ class MongoHook(BaseHook): """ - Interact with Mongo. This hook uses the Mongo conn_id. + PyMongo wrapper to interact with MongoDB. - PyMongo Wrapper to Interact With Mongo Database Mongo Connection Documentation https://docs.mongodb.com/manual/reference/connection-string/index.html You can specify connection string options in extra field of your connection @@ -54,7 +53,7 @@ class MongoHook(BaseHook): when connecting to MongoDB. """ - conn_name_attr = "conn_id" + conn_name_attr = "mongo_conn_id" default_conn_name = "mongo_default" conn_type = "mongo" hook_name = "MongoDB"