Add retries to ArchiveFetcher

Summary:
X-link: https://github.com/facebookincubator/zstrong/pull/1227

Add retries to ArchiveFetcher when downloading fails. There will be 4 retries, with backoff and jitter. The max delay is capped at 10 seconds.

Reviewed By: srikrishnagopu

Differential Revision: D71167342

fbshipit-source-id: d927a639cf99185c5a04d063400bdab874dfddfe

build/fbcode_builder/getdeps/fetcher.py

@@ -9,6 +9,7 @@
 import errno
 import hashlib
 import os
+import random
 import re
 import shutil
 import stat
@@ -837,7 +838,20 @@ class ArchiveFetcher(Fetcher):
 
     def _download(self) -> None:
         self._download_dir()
-        download_url_to_file_with_progress(self.url, self.file_name)
+        max_attempts = 5
+        delay = 1
+        for attempt in range(max_attempts):
+            try:
+                download_url_to_file_with_progress(self.url, self.file_name)
+                break
+            except TransientFailure as tf:
+                if attempt < max_attempts - 1:
+                    delay *= 2
+                    delay_with_jitter = delay * (1 + random.random() * 0.1)
+                    time.sleep(min(delay_with_jitter, 10))
+                else:
+                    print(f"Failed after retries: {tf}")
+                    raise
         self._verify_hash()
 
     def clean(self) -> None:

build/fbcode_builder/getdeps/test/retry_test.py

@@ -0,0 +1,167 @@
+# Copyright (c) Meta Platforms, Inc. and affiliates.
+#
+# This source code is licensed under the MIT license found in the
+# LICENSE file in the root directory of this source tree.
+
+# pyre-unsafe
+
+
+import unittest
+from unittest.mock import call, MagicMock, patch
+
+from ..buildopts import BuildOptions
+
+from ..errors import TransientFailure
+
+from ..fetcher import ArchiveFetcher
+from ..manifest import ManifestParser
+
+
+class RetryTest(unittest.TestCase):
+    def _get_build_opts(self) -> BuildOptions:
+        mock_build_opts = MagicMock(spec=BuildOptions)
+        mock_build_opts.scratch_dir = "/path/to/scratch_dir"
+        return mock_build_opts
+
+    def _get_manifest(self) -> ManifestParser:
+        mock_manifest_parser = MagicMock(spec=ManifestParser)
+        mock_manifest_parser.name = "mock_manifest_parser"
+        return mock_manifest_parser
+
+    def _get_archive_fetcher(self) -> ArchiveFetcher:
+        return ArchiveFetcher(
+            build_options=self._get_build_opts(),
+            manifest=self._get_manifest(),
+            url="https://github.com/systemd/systemd/archive/refs/tags/v256.7.tar.gz",
+            sha256="896d76ff65c88f5fd9e42f90d152b0579049158a163431dd77cdc57748b1d7b0",
+        )
+
+    @patch("os.makedirs")
+    @patch("os.environ.get")
+    @patch("time.sleep")
+    @patch("subprocess.run")
+    def test_no_retries(
+        self, mock_run, mock_sleep, mock_os_environ_get, mock_makedirs
+    ) -> None:
+        def custom_makedirs(path, exist_ok=False):
+            return None
+
+        def custom_get(key, default=None):
+            if key == "GETDEPS_USE_WGET":
+                return "1"
+            elif key == "GETDEPS_WGET_ARGS":
+                return ""
+            else:
+                return None
+
+        mock_makedirs.side_effect = custom_makedirs
+        mock_os_environ_get.side_effect = custom_get
+        mock_sleep.side_effect = None
+        fetcher = self._get_archive_fetcher()
+        fetcher._verify_hash = MagicMock(return_value=None)
+        fetcher._download()
+        mock_sleep.assert_has_calls([], any_order=False)
+        mock_run.assert_called_once_with(
+            [
+                "wget",
+                "-O",
+                "/path/to/scratch_dir/downloads/mock_manifest_parser-v256.7.tar.gz",
+                "https://github.com/systemd/systemd/archive/refs/tags/v256.7.tar.gz",
+            ],
+            capture_output=True,
+        )
+
+    @patch("random.random")
+    @patch("os.makedirs")
+    @patch("os.environ.get")
+    @patch("time.sleep")
+    @patch("subprocess.run")
+    def test_retries(
+        self, mock_run, mock_sleep, mock_os_environ_get, mock_makedirs, mock_random
+    ) -> None:
+        def custom_makedirs(path, exist_ok=False):
+            return None
+
+        def custom_get(key, default=None):
+            if key == "GETDEPS_USE_WGET":
+                return "1"
+            elif key == "GETDEPS_WGET_ARGS":
+                return ""
+            else:
+                return None
+
+        mock_random.return_value = 0
+
+        mock_run.side_effect = [
+            IOError("<urlopen error [Errno 104] Connection reset by peer>"),
+            IOError("<urlopen error [Errno 104] Connection reset by peer>"),
+            None,
+        ]
+        mock_makedirs.side_effect = custom_makedirs
+        mock_os_environ_get.side_effect = custom_get
+        mock_sleep.side_effect = None
+        fetcher = self._get_archive_fetcher()
+        fetcher._verify_hash = MagicMock(return_value=None)
+        fetcher._download()
+        mock_sleep.assert_has_calls([call(2), call(4)], any_order=False)
+        calls = [
+            call(
+                [
+                    "wget",
+                    "-O",
+                    "/path/to/scratch_dir/downloads/mock_manifest_parser-v256.7.tar.gz",
+                    "https://github.com/systemd/systemd/archive/refs/tags/v256.7.tar.gz",
+                ],
+                capture_output=True,
+            ),
+        ] * 3
+
+        mock_run.assert_has_calls(calls, any_order=False)
+
+    @patch("random.random")
+    @patch("os.makedirs")
+    @patch("os.environ.get")
+    @patch("time.sleep")
+    @patch("subprocess.run")
+    def test_all_retries(
+        self, mock_run, mock_sleep, mock_os_environ_get, mock_makedirs, mock_random
+    ) -> None:
+        def custom_makedirs(path, exist_ok=False):
+            return None
+
+        def custom_get(key, default=None):
+            if key == "GETDEPS_USE_WGET":
+                return "1"
+            elif key == "GETDEPS_WGET_ARGS":
+                return ""
+            else:
+                return None
+
+        mock_random.return_value = 0
+
+        mock_run.side_effect = IOError(
+            "<urlopen error [Errno 104] Connection reset by peer>"
+        )
+        mock_makedirs.side_effect = custom_makedirs
+        mock_os_environ_get.side_effect = custom_get
+        mock_sleep.side_effect = None
+        fetcher = self._get_archive_fetcher()
+        fetcher._verify_hash = MagicMock(return_value=None)
+        with self.assertRaises(TransientFailure):
+            fetcher._download()
+        mock_sleep.assert_has_calls(
+            [call(2), call(4), call(8), call(10)], any_order=False
+        )
+        calls = [
+            call(
+                [
+                    "wget",
+                    "-O",
+                    "/path/to/scratch_dir/downloads/mock_manifest_parser-v256.7.tar.gz",
+                    "https://github.com/systemd/systemd/archive/refs/tags/v256.7.tar.gz",
+                ],
+                capture_output=True,
+            ),
+        ] * 5
+
+        mock_run.assert_has_calls(calls, any_order=False)