File tree Expand file tree Collapse file tree 3 files changed +3
-4
lines changed
Expand file tree Collapse file tree 3 files changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -224,6 +224,7 @@ def quote_string(self, value: str) -> str:
224224 def get_master_table_name (self , part_table : str ) -> str | None :
225225 """Extract master table name from part table (MySQL backtick format)."""
226226 import re
227+
227228 # MySQL format: `schema`.`master__part`
228229 match = re .match (r"(?P<master>`\w+`.`#?\w+)__\w+`" , part_table )
229230 return match ["master" ] + "`" if match else None
Original file line number Diff line number Diff line change @@ -241,6 +241,7 @@ def quote_string(self, value: str) -> str:
241241 def get_master_table_name (self , part_table : str ) -> str | None :
242242 """Extract master table name from part table (PostgreSQL double-quote format)."""
243243 import re
244+
244245 # PostgreSQL format: "schema"."master__part"
245246 match = re .match (r'(?P<master>"\w+"."#?\w+)__\w+"' , part_table )
246247 return match ["master" ] + '"' if match else None
Original file line number Diff line number Diff line change @@ -526,10 +526,7 @@ def jobs(self) -> list[Job]:
526526 # Iterate over auto-populated tables and check if their job table exists
527527 for table_name in self .list_tables ():
528528 adapter = self .connection .adapter
529- full_name = (
530- f"{ adapter .quote_identifier (self .database )} ."
531- f"{ adapter .quote_identifier (table_name )} "
532- )
529+ full_name = f"{ adapter .quote_identifier (self .database )} ." f"{ adapter .quote_identifier (table_name )} "
533530 table = FreeTable (self .connection , full_name )
534531 tier = _get_tier (table .full_table_name )
535532 if tier in (Computed , Imported ):
You can’t perform that action at this time.
0 commit comments