Update db_operations/db_operations.py

db_operations/db_operations.py

@@ -14,7 +14,7 @@ class DBOperations:
         self.__client = None
         self.__error = 0
 
-    def __connect(self):
+    async def __connect(self):
         try:
             self.__client = pymongo.MongoClient(self.url)
             _ = self.__client.list_database_names()
@@ -23,7 +23,7 @@ class DBOperations:
             self.__client = None
             raise
 
-    def __read(self):
+    async def __read(self):
         try:
             db = self.__client[self.database]
             coll = db[self.collection]
@@ -43,17 +43,18 @@ class DBOperations:
             self.__client.close()
             self.__client = None
 
-    def read_news_from_db(self):
+    async def read_news_from_db(self):
         rss_df = pd.DataFrame({'_id': '', 'title': '', 'url': '',
                                'description': '', 'parsed_date': '',
                                'src': ''}, index=[0])
         if self.url is not None:
             if self.__error == 0:
-                self.__connect()
+                await self.__connect()
             if self.__error == 0:
-                rss_df = self.__read()
+                rss_df = await self.__read()
             if self.__error == 0:
                 print("Read Successful")
             if self.__client is not None:
                 self.__close_connection()
         return rss_df
+