@@ -135,32 +135,6 @@ def skip_table_or_view(self, schema_name: str, table_name: str, load_table: Call
135
135
except BadRequest as err :
136
136
logger .error (f"Failed to apply skip marker for Table { schema_name } .{ table_name } : { err !s} " , exc_info = True )
137
137
138
- def unskip_table_or_view (
139
- self , schema_name : str , table_name : str , load_table : Callable [[str , str ], Table | None ]
140
- ) -> None :
141
- """Removes skip mark from the table property..
142
- Args:
143
- schema_name (String): The schema name of the table to be unskipped.
144
- table_name (String): The table name of the table to be unskipped.
145
- load_table (Callable): A function that loads a table from the metastore.
146
- """
147
- table = load_table (schema_name , table_name )
148
- if table is None :
149
- raise NotFound ("[TABLE_OR_VIEW_NOT_FOUND]" )
150
- try :
151
- self ._sql_backend .execute (
152
- f"ALTER { table .kind } { escape_sql_identifier (schema_name )} .{ escape_sql_identifier (table_name )} UNSET TBLPROPERTIES IF EXISTS('{ self .UCX_SKIP_PROPERTY } ');"
153
- )
154
- except NotFound as e :
155
- if "[TABLE_OR_VIEW_NOT_FOUND]" in str (e ) or "[DELTA_TABLE_NOT_FOUND]" in str (e ):
156
- logger .error (
157
- f"Failed to remove skip marker from table: { schema_name } .{ table_name } . Table not found." , exc_info = e
158
- )
159
- else :
160
- logger .error (f"Failed to remove skip marker from table: { schema_name } .{ table_name } " , exc_info = e )
161
- except BadRequest as e :
162
- logger .error (f"Failed to remove skip marker from table: { schema_name } .{ table_name } : { e !s} " , exc_info = e )
163
-
164
138
def skip_schema (self , schema : str ):
165
139
# Marks a schema to be skipped in the migration process by applying a table property
166
140
try :
0 commit comments