@@ -252,7 +252,9 @@ def _construct_table_input(
252252def _construct_rename_table_input (to_table_name : str , glue_table : "TableTypeDef" ) -> "TableInputTypeDef" :
253253 rename_table_input : "TableInputTypeDef" = {"Name" : to_table_name }
254254 # use the same Glue info to create the new table, pointing to the old metadata
255- assert glue_table ["TableType" ]
255+ if not glue_table ["TableType" ]:
256+ raise ValueError ("Glue table type is missing, cannot rename table" )
257+
256258 rename_table_input ["TableType" ] = glue_table ["TableType" ]
257259 if "Owner" in glue_table :
258260 rename_table_input ["Owner" ] = glue_table ["Owner" ]
@@ -347,9 +349,14 @@ def __init__(self, name: str, client: Optional["GlueClient"] = None, **propertie
347349 def _convert_glue_to_iceberg (self , glue_table : "TableTypeDef" ) -> Table :
348350 properties : Properties = glue_table ["Parameters" ]
349351
350- assert glue_table ["DatabaseName" ]
351- assert glue_table ["Parameters" ]
352- database_name = glue_table ["DatabaseName" ]
352+ database_name = glue_table .get ("DatabaseName" , None )
353+ if database_name is None :
354+ raise ValueError ("Glue table is missing DatabaseName property" )
355+
356+ parameters = glue_table .get ("Parameters" , None )
357+ if parameters is None :
358+ raise ValueError ("Glue table is missing Parameters property" )
359+
353360 table_name = glue_table ["Name" ]
354361
355362 if TABLE_TYPE not in properties :
0 commit comments