source-facebook-marketing: validate account ids

source-facebook-marketing/source_facebook_marketing/source.py

@@ -34,7 +34,7 @@
     Videos,
 )
 
-from .utils import validate_end_date, validate_start_date
+from .utils import validate_end_date, validate_start_date, validate_account_ids
 
 logger = logging.getLogger("airbyte")
 UNSUPPORTED_FIELDS = {"unique_conversions", "unique_ctr", "unique_clicks",
@@ -96,6 +96,8 @@ def streams(self, config: Mapping[str, Any]) -> List[Type[Stream]]:
 
         api = API(access_token=config.credentials.access_token)
 
+        validate_account_ids(api, config.account_ids)
+
         insights_args = dict(
             api=api, start_date=config.start_date, end_date=config.end_date, insights_lookback_window=config.insights_lookback_window, account_ids=config.account_ids,
         )

source-facebook-marketing/source_facebook_marketing/utils.py

@@ -3,9 +3,13 @@
 #
 
 import logging
+from typing import List
 
 import pendulum
 from pendulum import DateTime
+from estuary_cdk.flow import ValidationError
+
+from source_facebook_marketing.api import API, FacebookAPIException
 
 logger = logging.getLogger("airbyte")
 
@@ -45,3 +49,15 @@ def validate_end_date(start_date: DateTime, end_date: DateTime) -> DateTime:
         logger.warning(message)
         return start_date
     return end_date
+
+def validate_account_ids(api: API, account_ids: List[str]):
+    errs = []
+    for account_id in account_ids:
+        try:
+            api._find_account(account_id)
+        except FacebookAPIException as err:
+            msg = f"Error when validating account ID {account_id}: {err}"
+            errs.append(msg)
+
+    if len(errs) > 0:
+        raise ValidationError(errs)