Change timeouts and retry (#289)

AudiusProject · Feb 11, 2020 · 8014be1 · 8014be1
1 parent 42203e6
commit 8014be1
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/creator-node/src/middlewares.js b/creator-node/src/middlewares.js
@@ -163,7 +163,7 @@ async function _getCreatorNodeEndpoints (req, wallet) {
     let discprovBlockNumber = -1
     const start2 = Date.now()
 
-    const maxRetries = 10
+    const maxRetries = 20
     for (let retry = 1; retry <= maxRetries; retry++) {
       req.logger.info(`_getCreatorNodeEndpoints retry #${retry}/${maxRetries} || time from start: ${Date.now() - start2} discprovBlockNumber ${discprovBlockNumber} || blockNumber ${blockNumber}`)
       try {

diff --git a/discovery-provider/src/utils/ipfs_lib.py b/discovery-provider/src/utils/ipfs_lib.py
@@ -99,7 +99,7 @@ def get_metadata_from_gateway(self, multihash, metadata_format):
 
             try:
                 logger.warning(f"IPFSCLIENT | Querying {gateway_query_address}")
-                r = requests.get(gateway_query_address, timeout=10)
+                r = requests.get(gateway_query_address, timeout=8)
 
                 # Do not retrieve metadata for error code
                 if r.status_code != 200:
@@ -161,7 +161,7 @@ def get_metadata_from_ipfs_node(self, multihash, metadata_format):
 
     def cat(self, multihash):
         try:
-            res = self._api.cat(multihash, timeout=20)
+            res = self._api.cat(multihash, timeout=8)
             return res
         except:
             logger.error(f"IPFSCLIENT | IPFS cat timed out for CID {multihash}")
@@ -186,7 +186,7 @@ def multihash_is_directory(self, multihash):
             r = None
             try:
                 logger.warning(f"IPFSCLIENT | Querying {gateway_query_address}")
-                r = requests.get(gateway_query_address, timeout=10)
+                r = requests.get(gateway_query_address, timeout=8)
             except Exception as e:
                 logger.warning(f"Failed to query {gateway_query_address} with error {e}")
 
@@ -210,7 +210,7 @@ def multihash_is_directory(self, multihash):
             r = None
             try:
                 logger.warning(f"IPFSCLIENT | Querying {gateway_query_address}")
-                r = requests.get(gateway_query_address, timeout=10)
+                r = requests.get(gateway_query_address, timeout=8)
             except Exception as e:
                 logger.warning(f"Failed to query {gateway_query_address}, {e}")