Limit number of peers to source answer from

rtrevinnoc · Feb 13, 2021 · dae30a3 · dae30a3
1 parent d8306e0
commit dae30a3
Showing 1 changed file with 8 additions and 8 deletions.
diff --git a/future.py b/future.py
@@ -277,11 +277,11 @@ async def getDataFromPeers(query, queryVector, queryLanguage, numberOfURLs,
         listOfResponses = []
         for response in await asyncio.gather(*futures):
             listOfResponses.append(response)
-            if numberOfPeers >= 5:
-                if len(listOfResponses) == 5:
-                    return listOfResponses
-            else:
+            if numberOfPeers >= 5 and len(listOfResponses) == 5:
                 return listOfResponses
+            else:
+                continue
+        return listOfResponses
 
 
 async def getImagesFromPeers(query, queryVector, queryLanguage, numberOfURLs,
@@ -299,11 +299,11 @@ async def getImagesFromPeers(query, queryVector, queryLanguage, numberOfURLs,
         listOfResponses = []
         for response in await asyncio.gather(*futures):
             listOfResponses.append(response)
-            if numberOfPeers >= 5:
-                if len(listOfResponses) == 5:
-                    return listOfResponses
-            else:
+            if numberOfPeers >= 5 and len(listOfResponses) == 5:
                 return listOfResponses
+            else:
+                continue
+        return listOfResponses
 
 
 def loadMoreUrls(q_vec: np.ndarray, queryLanguage: str, numberOfURLs: int,