2424
2525DOCUMENTATION = r'''
2626---
27- module: dw_dbc
27+ module: dw_database_catalog
2828short_description: Create CDP Data Warehouse Database Catalog
2929description:
3030 - Create CDP Database Catalog
8686# Note: These examples do not set authentication details.
8787
8888# Create Database Catalog
89- - cloudera.cloud.dw_dbc :
89+ - cloudera.cloud.dw_database_catalog :
9090 name: "example-database-catalog-name"
9191 cluster_id: "example-cluster-id"
9292
9393# Delete Database Catalog
94- - cloudera.cloud.dw_dbc :
94+ - cloudera.cloud.dw_database_catalog :
9595 id: "example-database-id"
9696 cluster_id: "example-cluster-id"
9797 state: "absent"
9898'''
9999
100100RETURN = r'''
101101---
102- dbcs :
102+ database_catalogs :
103103 description: The information about the named Database Catalog.
104104 type: list
105105 returned: always
@@ -144,7 +144,7 @@ def __init__(self, module):
144144 self .timeout = self ._get_param ('timeout' )
145145
146146 # Initialize return values
147- self .dbcs = []
147+ self .database_catalogs = []
148148
149149 # Initialize internal values
150150 self .target = None
@@ -165,7 +165,7 @@ def process(self):
165165 if self .target is not None :
166166 if self .state == 'absent' :
167167 if self .module .check_mode :
168- self .dbcs .append (self .target )
168+ self .database_catalogs .append (self .target )
169169 else :
170170 if self .target ['status' ] not in self .cdpy .sdk .REMOVABLE_STATES :
171171 self .module .warn (
@@ -179,9 +179,9 @@ def process(self):
179179 field = None , delay = self .delay , timeout = self .timeout
180180 )
181181 else :
182- self .cdpy .sdk .sleep (3 ) # Wait for consistency sync
182+ self .cdpy .sdk .sleep (self . delay ) # Wait for consistency sync
183183 self .target = self .cdpy .dw .describe_dbc (cluster_id = self .cluster_id , dbc_id = self .target ['id' ])
184- self .dbcs .append (self .target )
184+ self .database_catalogs .append (self .target )
185185 # Drop Done
186186 elif self .state == 'present' :
187187 # Begin Config check
@@ -192,7 +192,7 @@ def process(self):
192192 params = dict (cluster_id = self .cluster_id , dbc_id = self .target ['id' ]),
193193 state = self .cdpy .sdk .STARTED_STATES , delay = self .delay , timeout = self .timeout
194194 )
195- self .dbcs .append (self .target )
195+ self .database_catalogs .append (self .target )
196196 # End Config check
197197 else :
198198 self .module .fail_json (msg = "State %s is not valid for this module" % self .state )
@@ -215,7 +215,7 @@ def process(self):
215215 )
216216 else :
217217 self .target = self .cdpy .dw .describe_dbc (cluster_id = self .cluster_id , dbc_id = dbc_id )
218- self .dbcs .append (self .target )
218+ self .database_catalogs .append (self .target )
219219 else :
220220 self .module .fail_json (msg = "State %s is not valid for this module" % self .state )
221221
@@ -236,7 +236,7 @@ def main():
236236 )
237237
238238 result = DwDbc (module )
239- output = dict (changed = False , dbcs = result .dbcs )
239+ output = dict (changed = False , database_catalogs = result .database_catalogs )
240240
241241 if result .debug :
242242 output .update (sdk_out = result .log_out , sdk_out_lines = result .log_lines )
0 commit comments