diff --git a/ingestion/src/metadata/ingestion/source/bigquery.py b/ingestion/src/metadata/ingestion/source/bigquery.py index d8661f65cf3..a6a44a4167f 100644 --- a/ingestion/src/metadata/ingestion/source/bigquery.py +++ b/ingestion/src/metadata/ingestion/source/bigquery.py @@ -151,9 +151,8 @@ class BigquerySource(SQLSource): return TableData(columns=cols, rows=rows) except Exception as err: logger.error(err) - return [] - - super().fetch_sample_data(schema, table) + else: + return super().fetch_sample_data(schema, table) def _get_database(self, database: Optional[str]) -> Database: if not database: