fix(source-marketo): handle missing 'result' key in Marketo API responses (AI-Triage PR) (#73309)

Co-authored-by: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com>

Author: devin-ai-integration[bot]

airbyte-integrations/connectors/source-marketo/metadata.yaml

@@ -10,7 +10,7 @@ data:
   connectorSubtype: api
   connectorType: source
   definitionId: 9e0556f4-69df-4522-a3fb-03264d36b348
-  dockerImageTag: 1.4.39
+  dockerImageTag: 1.4.40
   dockerRepository: airbyte/source-marketo
   documentationUrl: https://docs.airbyte.com/integrations/sources/marketo
   githubIssueLabel: source-marketo

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

@@ -3,7 +3,7 @@ requires = [ "poetry-core>=1.0.0",]
 build-backend = "poetry.core.masonry.api"
 
 [tool.poetry]
-version = "1.4.39"
+version = "1.4.40"
 name = "source-marketo"
 description = "Source implementation for Marketo."
 authors = [ "Airbyte <contact@airbyte.io>",]

airbyte-integrations/connectors/source-marketo/source_marketo/source.py

@@ -303,8 +303,11 @@ def should_retry(self, response: requests.Response) -> bool:
             if errors[0].get("code") == "1029" and re.match("Export daily quota \d+MB exceeded", errors[0].get("message")):
                 message = "Daily limit for job extractions has been reached (resets daily at 12:00AM CST)."
                 raise AirbyteTracedException(internal_message=response.text, message=message, failure_type=FailureType.config_error)
-        result = response.json().get("result")[0]
-        status, export_id = result.get("status", "").lower(), result.get("exportId")
+        result = response.json().get("result")
+        if not result:
+            self.logger.warning("No 'result' in export create response, retrying. Response: %s", response.text[:500])
+            return True
+        status, export_id = result[0].get("status", "").lower(), result[0].get("exportId")
         if status != "created" or not export_id:
             self.logger.warning(f"Failed to create export job! Status is {status}!")
             return True
@@ -349,7 +352,12 @@ def path(self, **kwargs) -> str:
         return f"bulk/v1/{self.stream_name}/export/{self.export_id}/status.json"
 
     def parse_response(self, response: requests.Response, **kwargs) -> List[str]:
-        return [response.json()[self.data_field][0]["status"]]
+        result = response.json().get(self.data_field)
+        if not result:
+            raise Exception(
+                f"Unexpected response from export status endpoint: '{self.data_field}' key missing. Response: {response.text[:500]}"
+            )
+        return [result[0]["status"]]
 
 
 class Leads(MarketoExportBase):

docs/integrations/sources/marketo.md

@@ -121,6 +121,7 @@ If the 50,000 limit is too stringent, contact Marketo support for a quota increa
 
 | Version  | Date       | Pull Request                                             | Subject                                                                                          |
 |:---------|:-----------|:---------------------------------------------------------|:-------------------------------------------------------------------------------------------------|
+| 1.4.40 | 2026-02-12 | [TBD](https://github.com/airbytehq/airbyte/pull/TBD) | Fix KeyError and TypeError when Marketo API responses lack 'result' key in export status and create endpoints |
 | 1.4.39 | 2026-01-26 | [71849](https://github.com/airbytehq/airbyte/pull/71849) | Add error handling for type conversion in format_value |
 | 1.4.38 | 2025-10-21 | [68475](https://github.com/airbytehq/airbyte/pull/68475) | Update dependencies |
 | 1.4.37 | 2025-10-14 | [67858](https://github.com/airbytehq/airbyte/pull/67858) | Update dependencies |