@@ -116,23 +116,22 @@ def get_seen_tables(self, *, scope: set[Table] | None = None) -> dict[str, str]:
116
116
schema .name ,
117
117
)
118
118
)
119
- tables : list = []
120
- table_lists = Threads .gather ("list tables" , tasks , self .API_LIMIT )
121
- # Combine tuple of lists to a list
122
- for table_list in table_lists [0 ]:
123
- if table_list is not None :
124
- tables .extend (table_list )
125
- for table in tables :
126
- if not isinstance (table , TableInfo ):
127
- logger .warning (f"Table { table } is not an instance of TableInfo" )
128
- continue
129
- if not table .full_name :
130
- logger .warning (f"The table { table .name } in { schema .name } has no full name" )
131
- continue
132
- if table_scope and table .full_name .lower () not in table_scope :
133
- continue
134
- if not table .properties or "upgraded_from" not in table .properties :
135
- continue
119
+ tables : list = []
120
+ table_lists = Threads .gather ("list tables" , tasks , self .API_LIMIT )
121
+ # Combine tuple of lists to a list
122
+ for table_list in table_lists :
123
+ tables .extend (table_list )
124
+ for table in tables :
125
+ if not isinstance (table , TableInfo ):
126
+ logger .warning (f"Table { table } is not an instance of TableInfo" )
127
+ continue
128
+ if not table .full_name :
129
+ logger .warning (f"The table { table .name } in { schema .name } has no full name" )
130
+ continue
131
+ if table_scope and table .full_name .lower () not in table_scope :
132
+ continue
133
+ if not table .properties or "upgraded_from" not in table .properties :
134
+ continue
136
135
137
136
seen_tables [table .full_name .lower ()] = table .properties ["upgraded_from" ].lower ()
138
137
return seen_tables
0 commit comments