retry on timeout

tap_facebook/streams.py

@@ -1,5 +1,6 @@
 import singer
 import time
+from requests.exceptions import ReadTimeout
 from typing import Any, Sequence, Union, Optional, Dict, cast, List
 from datetime import timedelta, datetime, date
 from dateutil import parser
@@ -10,6 +11,7 @@
 from facebook_business.adobjects.adsinsights import AdsInsights
 from facebook_business.adobjects.adreportrun import AdReportRun
 
+
 logger = singer.get_logger()
 
 
@@ -19,7 +21,6 @@ def __init__(self, config):
         self.bookmark_key = "date_start"
 
     def stream(self, account_ids: Sequence[str], state: dict, tap_stream_id: str):
-
         for account_id in account_ids:
             state = self.process_account(
                 account_id, tap_stream_id=tap_stream_id, state=state
@@ -101,7 +102,7 @@ def process_account(
             else:
                 time_ranges = [(since, until)]
             try:
-                for (start, stop) in time_ranges:
+                for start, stop in time_ranges:
                     timerange = {"since": str(start), "until": str(stop)}
                     params = {
                         "level": "ad",
@@ -193,7 +194,9 @@ def __get_start(self, account_id, state: dict, tap_stream_id: str) -> datetime:
         logger.info(f"using 'start_date' from previous state: {current_bookmark}")
         return parser.isoparse(current_bookmark)
 
-    @backoff.on_exception(backoff.expo, FacebookRequestError, max_tries=5, base=5)
+    @backoff.on_exception(
+        backoff.expo, (FacebookRequestError, ReadTimeoutError), max_tries=5, base=5
+    )
     def __retrieve_job(self, async_job) -> AdReportRun:
         job = cast(AdReportRun, async_job.api_get())
         return job