✨ Source Facebook Marketing: Add learning_stage_info field to AdSets stream (#50418)

Co-authored-by: Marcos Marx <marcosmarxm@users.noreply.github.com>
Co-authored-by: marcosmarxm <marcosmarxm@gmail.com>

Author: jake horban

airbyte-integrations/connectors/source-facebook-marketing/metadata.yaml

@@ -10,7 +10,7 @@ data:
   connectorSubtype: api
   connectorType: source
   definitionId: e7778cfc-e97c-4458-9ecb-b4f2bba8946c
-  dockerImageTag: 3.3.35
+  dockerImageTag: 3.4.0
   dockerRepository: airbyte/source-facebook-marketing
   documentationUrl: https://docs.airbyte.com/integrations/sources/facebook-marketing
   githubIssueLabel: source-facebook-marketing

airbyte-integrations/connectors/source-facebook-marketing/poetry.lock

@@ -3,7 +3,7 @@ requires = [ "poetry-core>=1.0.0",]
 build-backend = "poetry.core.masonry.api"
 
 [tool.poetry]
-version = "3.3.35"
+version = "3.4.0"
 name = "source-facebook-marketing"
 description = "Source implementation for Facebook Marketing."
 authors = [ "Airbyte <contact@airbyte.io>",]

airbyte-integrations/connectors/source-facebook-marketing/pyproject.toml

@@ -161,6 +161,32 @@
           }
         }
       }
+    },
+    "learning_stage_info": {
+      "description": "Info about whether the ranking or delivery system is still learning for this ad set.",
+      "type": ["null", "object"],
+      "properties": {
+        "status": {
+          "description": "Learning Phase progress for the ad set. Values: LEARNING — The ad set is still learning. SUCCESS — The ad set exited the learning phase. FAIL — The ad set isn’t generating enough results to exit the learning phase.",
+          "type": ["null", "string"]
+        },
+        "conversions": {
+          "description": "Number of conversions the ad set generated since the time of its last significant edit during the learning phase. Significant edits cause ad sets to reenter the learning phase.",
+          "type": ["null", "integer"]
+        },
+        "last_sig_edit_ts": {
+          "description": "Timestamp of the last significant edit that caused ad set to reenter the learning phase.",
+          "type": ["null", "integer"]
+        },
+        "attribution_windows": {
+          "description": "List of configured attribution windows.",
+          "type": ["null", "array"],
+          "items": {
+            "description": "Number of days between when a person viewed or clicked your ad and subsequently took action. By default, the attribution window is set to 1-day view and 28-day click.",
+            "type": ["null", "string"]
+          }
+        }
+      }
     }
   }
 }

airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/schemas/ad_sets.json

@@ -175,6 +175,7 @@ def test_ad_sets_stream(self, http_mocker: HttpMocker):
             "bid_amount",
             "bid_constraints",
             "adlabels",
+            "learning_stage_info",
         ]
 
         http_mocker.get(

airbyte-integrations/connectors/source-facebook-marketing/unit_tests/integration/test_include_deleted.py

@@ -34,7 +34,13 @@
         "REACH": 99
       },
       "bid_strategy": "COST_CAP",
-      "bid_amount": 99.0
+      "bid_amount": 99.0,
+      "learning_stage_info": {
+        "status": "LEARNING",
+        "conversions": 12,
+        "last_sig_edit_ts": 1734947501,
+        "attribution_windows": ["7d_click", "1d_view"]
+      }
     }
   ]
 }

airbyte-integrations/connectors/source-facebook-marketing/unit_tests/resource/http/response/ad_sets.json

@@ -334,15 +334,16 @@ def test_get_result_retried(self, mocker, job, api):
         api.call().json.return_value = {"data": [{"some_data": 123}, {"some_data": 77}]}
         ads_insights = AdsInsights(api=api)
         ads_insights._set_data({"items": [{"some_data": 123}, {"some_data": 77}]})
-        with mocker.patch(
+        mocker.patch(
             "facebook_business.adobjects.objectparser.ObjectParser.parse_multiple",
             side_effect=[
                 FacebookBadObjectError("Bad data to set object data"),
                 ads_insights,
             ],
-        ):
-            # in case this is not retried, an error will be raised
-            job.get_result()
+        )
+
+        # in case this is not retried, an error will be raised
+        job.get_result()
 
     def test_get_result_when_job_is_not_started(self, job):
         with pytest.raises(

airbyte-integrations/connectors/source-facebook-marketing/unit_tests/test_async_job.py

@@ -269,6 +269,7 @@ This response indicates that the Facebook Graph API requires you to reduce the f
 
 | Version | Date       | Pull Request                                             | Subject                                                                                                                                                                                                                                                                                           |
 |:--------|:-----------|:---------------------------------------------------------|:--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
+| 3.4.0 | 2024-12-24 | [50418](https://github.com/airbytehq/airbyte/pull/50418) | Add `learning_stage_info` field to `ad_sets` stream |
 | 3.3.35 | 2025-03-08 | [55307](https://github.com/airbytehq/airbyte/pull/55307) | Update dependencies |
 | 3.3.34 | 2025-03-01 | [54990](https://github.com/airbytehq/airbyte/pull/54990) | Update dependencies |
 | 3.3.33 | 2025-02-22 | [54386](https://github.com/airbytehq/airbyte/pull/54386) | Update dependencies |