Merge pull request #479 from emilyzheng/retry-brew-request

Retry brew requests [CLOUDDST-22680]

Author: emilyzheng

src/pushsource/_impl/backend/koji_source.py

@@ -248,7 +248,7 @@ def _koji_session(self):
             tls = self._cache.setdefault("tls", threading.local())
             if not hasattr(tls, "koji_session"):
                 LOG.debug("Creating koji session: %s", self._url)
-                tls.koji_session = koji.ClientSession(self._url)
+                tls.koji_session = koji.ClientSession(self._url, {"anon_retry": True})
         return tls.koji_session
 
     def _koji_check(self):

tests/koji/fake_koji.py

@@ -21,7 +21,7 @@ def reset(self):
         self.last_url = None
         self.next_build_id = 80000
 
-    def session(self, url):
+    def session(self, url, opts=None):
         self.last_url = url
         return FakeKojiSession(self)
 

tests/koji/test_koji.py

@@ -26,7 +26,8 @@ def test_koji_empty(fake_koji):
     assert list(source) == []
 
 
-def test_koji_connect_error():
+@patch("time.sleep")
+def test_koji_connect_error(time_sleep):
     """Source raises a reasonable error if server can't be contacted"""
 
     # Note: fake_koji fixture not used here, so this will really try to connect