@@ -201,7 +201,7 @@ def _install_spark_config_for_hms_lineage(self):
201201 gscript = hms_lineage .check_lineage_spark_config_exists ()
202202 if gscript :
203203 if gscript .enabled :
204- logger .info ("Already exists and enabled. Skipped creating a new one." )
204+ logger .info ("Global Init Script already exists and enabled. Skipped creating a new one." )
205205 elif not gscript .enabled and self ._prompts :
206206 if self ._prompts .confirm (
207207 "Your Global Init Script with required spark config is disabled, Do you want to enable it?"
@@ -286,6 +286,7 @@ def _create_dashboards(self):
286286 @property
287287 def _warehouse_id (self ) -> str :
288288 if self .current_config .warehouse_id is not None :
289+ logger .info ("Fetching warehouse_id from a config" )
289290 return self .current_config .warehouse_id
290291 warehouses = [_ for _ in self ._ws .warehouses .list () if _ .warehouse_type == EndpointInfoWarehouseType .PRO ]
291292 warehouse_id = self .current_config .warehouse_id
@@ -863,7 +864,7 @@ def _remove_warehouse(self):
863864 try :
864865 warehouse_name = self ._ws .warehouses .get (self .current_config .warehouse_id ).name
865866 if warehouse_name .startswith (WAREHOUSE_PREFIX ):
866- logger .info ("Deleting warehouse_name." )
867+ logger .info (f "Deleting { warehouse_name } ." )
867868 self ._ws .warehouses .delete (id = self .current_config .warehouse_id )
868869 except InvalidParameterValue :
869870 logger .error ("Error accessing warehouse details" )
0 commit comments