diff --git a/tap_mysql/client.py b/tap_mysql/client.py index a50b2ee..c99fad7 100644 --- a/tap_mysql/client.py +++ b/tap_mysql/client.py @@ -260,6 +260,8 @@ def discover_catalog_entries(self) -> list[dict]: ) custom_result = connection.execute(query) custom_rec = custom_result.fetchone() + if not custom_rec: + continue # inject the table_schema into the list of columns custom_rec_keys = list(custom_rec._fields) + ["mysql_schema"]