retry on transfer errors (#1203)

Author: AndreyNikiforov

.gitignore

@@ -23,4 +23,5 @@ node_modules/
 /package.json
 /package-lock.json
 # used for local troubleshooting
-.photos
+.photos
+.cookies/

CHANGELOG.md

@@ -2,6 +2,8 @@
 
 ## Unreleased
 
+- fix: transfer chunk issues terminate with error [#1202](https://github.com/icloud-photos-downloader/icloud_photos_downloader/issues/1202)
+
 ## 1.29.2 (2025-07-21)
 
 - fix: emulating old browser and client version fails authentication [#1073](https://github.com/icloud-photos-downloader/icloud_photos_downloader/issues/1073)

src/icloudpd/base.py

@@ -4,7 +4,13 @@
 from multiprocessing import freeze_support
 
 from requests import Timeout
-from requests.exceptions import ConnectionError
+from requests.exceptions import (
+    ChunkedEncodingError,
+    ConnectionError,
+    ContentDecodingError,
+    StreamConsumedError,
+    UnrewindableBodyError,
+)
 from urllib3.exceptions import NewConnectionError
 
 import foundation
@@ -1311,7 +1317,7 @@ def core(
     skip_bar = not os.environ.get("FORCE_TQDM") and (
         only_print_filenames or no_progress_bar or not sys.stdout.isatty()
     )
-    while True:  # watch with interval
+    while True:  # watch with interval & retry
         try:
             icloud = authenticator(
                 logger,
@@ -1542,6 +1548,16 @@ def should_break(counter: Counter) -> bool:
                 return 1
             else:
                 pass
+        except (
+            ChunkedEncodingError,
+            ContentDecodingError,
+            StreamConsumedError,
+            UnrewindableBodyError,
+        ) as error:
+            logger.debug(error)
+            logger.debug("Retrying...")
+            # these errors we can safely retry
+            continue
         if watch_interval:  # pragma: no cover
             logger.info(f"Waiting for {watch_interval} sec...")
             interval: Sequence[int] = range(1, watch_interval)