drop! Make TDR requests raise a LimitedTimeoutException

Author: dsotirho-ucsc

src/azul/http.py

@@ -1,4 +1,5 @@
 import logging
+import random
 import sys
 import time
 from typing import (
@@ -290,6 +291,9 @@ def retries(self) -> int:
 
     def urlopen(self, method, url, *args, **kwargs) -> urllib3.HTTPResponse:
         timeout, retries = self.timeout, self.retries
+        if '/snapshots/roleMap' in url and random.randint(0, 4) == 0:
+            time.sleep(5)
+            timeout = 0.1
         require('retries' not in kwargs, "Argument 'retries' is disallowed")
         retry = _LimitedRetry.create(retries=retries, timeout=timeout)
         try:

src/azul/service/source_service.py

@@ -68,6 +68,7 @@ def list_source_ids(self,
         cache_key = joiner.join(cache_key)
         try:
             source_ids = set(self._get(cache_key))
+            raise CacheMiss()
         except CacheMiss:
             source_ids = plugin.list_source_ids(authentication)
             self._put(cache_key, list(source_ids))