fix(source-facebook-marketing): Fix Facebook Marketing UTC hardcoding with per-account timezone detection (#73281)

Co-authored-by: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com>
Co-authored-by: Octavia Squidington III <octavia-squidington-iii@users.noreply.github.com>
Co-authored-by: Alfredo Garcia <alfredo.garcia@hallmark.edu>

Author: 3 people

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

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

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

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

airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/api.py

@@ -197,4 +197,4 @@ def get_account(self, account_id: str) -> AdAccount:
     @staticmethod
     def _find_account(account_id: str) -> AdAccount:
         """Actual implementation of find account"""
-        return AdAccount(f"act_{account_id}").api_get()
+        return AdAccount(f"act_{account_id}").api_get(fields=["timezone_name"])

airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/streams/base_insight_streams.py

@@ -3,9 +3,10 @@
 #
 
 import logging
-from datetime import date, timedelta
+from datetime import date, datetime, timedelta
 from functools import cache, cached_property
 from typing import Any, Iterable, Iterator, List, Mapping, MutableMapping, Optional, Union
+from zoneinfo import ZoneInfo
 
 from facebook_business.exceptions import FacebookBadObjectError, FacebookRequestError
 
@@ -82,6 +83,7 @@ def __init__(
         super().__init__(**kwargs)
         self._start_date = self._start_date.date()
         self._end_date = self._end_date.date()
+        self._account_end_dates: dict[str, date] = {}
         self._custom_fields = fields
         if action_breakdowns_allow_empty:
             if action_breakdowns is not None:
@@ -282,14 +284,41 @@ def state(self, value: Mapping[str, Any]):
 
         self._next_cursor_values = self._get_start_date()
 
+    def _get_end_date_for_account(self, account_id: str) -> date:
+        """Compute the effective end date for a specific account based on its timezone.
+
+        The Facebook Insights API interprets time_range dates in the ad account's timezone.
+        For accounts ahead of UTC, the UTC date may lag behind the account's local date,
+        causing the current day's data to be missed. This adjusts the end date per account.
+        """
+        if account_id in self._account_end_dates:
+            return self._account_end_dates[account_id]
+
+        today_utc = ab_datetime_now().date()
+        if self._end_date < today_utc:
+            self._account_end_dates[account_id] = self._end_date
+            return self._end_date
+
+        account = self._api.get_account(account_id=account_id)
+        timezone_name = account.get("timezone_name")
+        if isinstance(timezone_name, str):
+            account_today = datetime.now(tz=ZoneInfo(timezone_name)).date()
+            end_date = max(self._end_date, account_today)
+        else:
+            end_date = self._end_date
+
+        self._account_end_dates[account_id] = end_date
+        return end_date
+
     def _date_intervals(self, account_id: str) -> Iterator[date]:
         """Get date period to sync"""
-        if self._end_date < self._next_cursor_values[account_id]:
+        end_date = self._get_end_date_for_account(account_id)
+        if end_date < self._next_cursor_values[account_id]:
             return
 
         # Generate date intervals manually using standard datetime arithmetic
         current_date = self._next_cursor_values[account_id]
-        while current_date <= self._end_date:
+        while current_date <= end_date:
             yield current_date
             current_date += timedelta(days=self.time_increment)
 

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

@@ -16,7 +16,7 @@
 
 
 def get_account_request(account_id: Optional[str] = ACCOUNT_ID) -> RequestBuilder:
-    return RequestBuilder.get_account_endpoint(access_token=ACCESS_TOKEN, account_id=account_id)
+    return RequestBuilder.get_account_endpoint(access_token=ACCESS_TOKEN, account_id=account_id).with_fields(["timezone_name"])
 
 
 def get_ads_request(account_id: Optional[str] = ACCOUNT_ID) -> RequestBuilder:

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

@@ -21,8 +21,8 @@ def build_response(
     return HttpResponse(body=json.dumps(body), status_code=status_code.value, headers=headers)
 
 
-def get_account_response(account_id: Optional[str] = ACCOUNT_ID) -> HttpResponse:
-    response = {"account_id": account_id, "id": f"act_{account_id}"}
+def get_account_response(account_id: Optional[str] = ACCOUNT_ID, timezone_name: str = "Etc/UTC") -> HttpResponse:
+    response = {"account_id": account_id, "id": f"act_{account_id}", "timezone_name": timezone_name}
     return build_response(body=response, status_code=HTTPStatus.OK)
 
 

docs/integrations/sources/facebook-marketing.md

@@ -412,6 +412,7 @@ Facebook’s Ads Insights API dynamically aggregates and filters metrics. Purcha
 
 | Version    | Date       | Pull Request                                             | Subject                                                                                                                                                                                                                                                                                           |
 |:-----------|:-----------|:---------------------------------------------------------|:--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
+| 5.0.1 | 2026-02-24 | [73281](https://github.com/airbytehq/airbyte/pull/73281) | fix(source-facebook-marketing): Fix Facebook Marketing UTC hardcoding with per-account timezone detection |
 | 5.0.0      | 2026-02-20 | [72779](https://github.com/airbytehq/airbyte/pull/72779) | Custom Insights streams now use level-based primary keys; removed deprecated `7d_view` and `28d_view` attribution window columns; removed `wish_bid` field. All users should refresh schema and reset affected streams.                                                                           |
 | 4.2.1 | 2026-02-09 | [72952](https://github.com/airbytehq/airbyte/pull/72952) | fix(source-facebook-marketing): classify 'Invalid OAuth access token' as config_error (AI-Triage PR) |
 | 4.2.0      | 2026-01-07 | [71029](https://github.com/airbytehq/airbyte/pull/71029) | Add 98 missing fields for custom insights streams including objective_results transformation                                                                                                                                                                                                      |