source-google-sheets: add debug logs to troubleshoot missing "properties" field

Author: Alex-Bair

airbyte-integrations/connectors/source-google-sheets/google_sheets_source/google_sheets_source.py

@@ -134,7 +134,7 @@ def read(
     ) -> Generator[AirbyteMessage, None, None]:
         client = GoogleSheetsClient(self.get_credentials(config))
 
-        sheet_to_column_name = Helpers.parse_sheet_and_column_names_from_catalog(catalog)
+        sheet_to_column_name = Helpers.parse_sheet_and_column_names_from_catalog(catalog, logger)
         spreadsheet_id = Helpers.get_spreadsheet_id(config["spreadsheet_id"])
 
         row_batch_size = config.get("row_batch_size", ROW_BATCH_SIZE)

airbyte-integrations/connectors/source-google-sheets/google_sheets_source/helpers.py

@@ -119,11 +119,13 @@ def get_first_row(client, spreadsheet_id: str, sheet_name: str) -> List[str]:
         return Helpers.get_formatted_row_values(first_row_data)
 
     @staticmethod
-    def parse_sheet_and_column_names_from_catalog(catalog: ConfiguredAirbyteCatalog) -> Dict[str, FrozenSet[str]]:
+    def parse_sheet_and_column_names_from_catalog(catalog: ConfiguredAirbyteCatalog, logger: AirbyteLogger) -> Dict[str, FrozenSet[str]]:
         sheet_to_column_name = {}
+        logger.debug("Parsing sheet and column names from catalog.")
         for configured_stream in catalog.streams:
             stream = configured_stream.stream
             sheet_name = stream.name
+            logger.debug(f"Attempting to parse sheet {sheet_name}. stream: {stream}, stream.json_schema: {stream.json_schema}")
             sheet_to_column_name[sheet_name] = frozenset(stream.json_schema["properties"].keys())
 
         return sheet_to_column_name

airbyte-integrations/connectors/source-google-sheets/unit_tests/test_helpers.py

@@ -145,7 +145,7 @@ def test_parse_sheet_and_column_names_from_catalog(self):
             ]
         )
 
-        actual = Helpers.parse_sheet_and_column_names_from_catalog(catalog)
+        actual = Helpers.parse_sheet_and_column_names_from_catalog(catalog, logger)
 
         expected = {sheet1: sheet1_columns, sheet2: sheet2_columns}
         self.assertEqual(actual, expected)