Update db_operations/db_operations.py

db_operations/db_operations.py

@@ -1,7 +1,6 @@
 import pymongo
 import os
 import pandas as pd
-import time
 import logging
 
 
@@ -33,11 +32,12 @@ class DBOperations:
             docs = []
             maxtries = 5
             ntry = 0
-            if (len(docs) == 0) and (ntry < maxtries):
+            
+            while (len(docs) == 0) and (ntry < maxtries):
                 for doc in coll.find():
                     docs.append(doc)
-                logging.info(f"DB Read try: {ntry}")
-                # time.sleep(1)
+                ntry += 1
+                logging.info(f"DB Read try: {ntry}")    
                 
             rss_df = pd.DataFrame(docs)
         except Exception as insert_err: