Update db_operations/db_operations.py

db_operations/db_operations.py

@@ -1,6 +1,8 @@
 import pymongo
 import os
 import pandas as pd
+import time
+import logging
 
 
 class DBOperations:
@@ -28,8 +30,14 @@ class DBOperations:
             db = self.__client[self.database]
             coll = db[self.collection]
             docs = []
-            for doc in coll.find():
-                docs.append(doc)
+            maxtries = 3
+            ntry = 0
+            if (len(docs) == 0) and (ntry < maxtries):
+                for doc in coll.find():
+                    docs.append(doc)
+                ntry += 1
+                time.sleep(5)
+                
             rss_df = pd.DataFrame(docs)
         except Exception as insert_err:
             self.__error = 1