🚨🚨 Source Sendgrid: migrate to low code

airbyte-integrations/bases/connector-acceptance-test/connector_acceptance_test/conftest.py

@@ -299,6 +299,8 @@ async def discovered_catalog_fixture(
 
     output = await docker_runner.call_discover(config=connector_config)
     catalogs = [message.catalog for message in output if message.type == Type.CATALOG]
+    if len(catalogs) == 0:
+        raise ValueError("No catalog message was emitted")
     return {stream.name: stream for stream in catalogs[-1].streams}
 
 
@@ -322,6 +324,8 @@ async def previous_discovered_catalog_fixture(
         )
         return None
     catalogs = [message.catalog for message in output if message.type == Type.CATALOG]
+    if len(catalogs) == 0:
+        raise ValueError("No catalog message was emitted")
     return {stream.name: stream for stream in catalogs[-1].streams}
 
 

airbyte-integrations/connectors/source-sendgrid/.coveragerc

@@ -1,3 +1,4 @@
 [run]
 omit = 
     source_sendgrid/run.py
+    source_sendgrid/__init__.py

airbyte-integrations/connectors/source-sendgrid/integration_tests/configured_catalog.json

@@ -47,7 +47,16 @@
     },
     {
       "stream": {
-        "name": "single_sends",
+        "name": "singlesends",
+        "json_schema": {},
+        "supported_sync_modes": ["full_refresh"]
+      },
+      "sync_mode": "full_refresh",
+      "destination_sync_mode": "overwrite"
+    },
+    {
+      "stream": {
+        "name": "singlesend_stats",
         "json_schema": {},
         "supported_sync_modes": ["full_refresh"]
       },
@@ -140,15 +149,6 @@
       "sync_mode": "incremental",
       "cursor_field": ["created"],
       "destination_sync_mode": "append"
-    },
-    {
-      "stream": {
-        "name": "unsubscribe_groups",
-        "json_schema": {},
-        "supported_sync_modes": ["full_refresh"]
-      },
-      "sync_mode": "full_refresh",
-      "destination_sync_mode": "overwrite"
     }
   ]
 }

airbyte-integrations/connectors/source-sendgrid/integration_tests/invalid_api_key.json

@@ -1,3 +1,3 @@
 {
-  "apikey": "wrong.api.key123"
+  "api_key": "wrong.api.key123"
 }

airbyte-integrations/connectors/source-sendgrid/integration_tests/invalid_time.json

@@ -1,4 +1,4 @@
 {
-  "apikey": "apikey",
-  "start_time": "some erroneous input"
+  "api_key": "apikey",
+  "start_date": "some erroneous input"
 }

airbyte-integrations/connectors/source-sendgrid/integration_tests/no_spam_reports_configured_catalog.json

@@ -47,7 +47,16 @@
     },
     {
       "stream": {
-        "name": "single_sends",
+        "name": "singlesends",
+        "json_schema": {},
+        "supported_sync_modes": ["full_refresh"]
+      },
+      "sync_mode": "full_refresh",
+      "destination_sync_mode": "overwrite"
+    },
+    {
+      "stream": {
+        "name": "singlesend_stats",
         "json_schema": {},
         "supported_sync_modes": ["full_refresh"]
       },

airbyte-integrations/connectors/source-sendgrid/pyproject.toml

@@ -17,7 +17,7 @@ include = "source_sendgrid"
 
 [tool.poetry.dependencies]
 python = "^3.9,<3.12"
-airbyte-cdk = "==0.51.39"
+airbyte-cdk = "==0.65.0"
 requests = "==2.31.0"
 pandas = "==2.1.1"
 backoff = "==2.2.1"