Fix refresh endpoint

jcjc712 · jcjc712 · commit 8493438fb120 · 2024-04-24T08:46:16.000-06:00
diff --git a/dataherald/db_scanner/sqlalchemy.py b/dataherald/db_scanner/sqlalchemy.py
@@ -70,7 +70,7 @@ def refresh_tables(
         rows = []
         for schema, tables in schemas_and_tables.items():
             stored_tables = repository.find_by(
-                {"db_connection_id": str(db_connection_id), "schema": schema}
+                {"db_connection_id": str(db_connection_id), "schema_name": schema}
             )
             stored_tables_list = [table.table_name for table in stored_tables]
 

Original file line number	Diff line number	Diff line change
`@@ -70,7 +70,7 @@ def refresh_tables(`
`70`	`70`	`rows = []`
`71`	`71`	`for schema, tables in schemas_and_tables.items():`
`72`	`72`	`stored_tables = repository.find_by(`
`73`		`- {"db_connection_id": str(db_connection_id), "schema": schema}`
	`73`	`+ {"db_connection_id": str(db_connection_id), "schema_name": schema}`
`74`	`74`	`)`
`75`	`75`	`stored_tables_list = [table.table_name for table in stored_tables]`
`76`	`76`