modified changes to Oee_handlers.py

scripts/core/handlers/oee_handlers.py

+import traceback
+
 from scripts.logging import logger
 from scripts.utils.mongo_util import MongoCollectionBaseClass
 from scripts.schemas.oee_config_schema import Oee_Tag_Mapping_List, Get_Oee_Tag, Update_Oee_Tags, Get_Project_Id
@@ -7,7 +9,6 @@ from scripts.db.mongo.ilens_configuration.collections import collection_constant
 from scripts.utils.mongo_util import MongoCollectionBaseClass
 from scripts.schemas import mongo_schema
 
-
 from scripts.constants.db_connections import mongo_client
 
 
@@ -16,7 +17,11 @@ class Oee_Services:
         try:
             self.connect = collection_constants(mongo_client=mongo_client)
         except Exception as e:
+            tb = traceback.format_exc()
+            logger.exception(e)
+            logger.exception(tb)
             logger.exception("Error while connecting to mongodb")
+            raise
 
     def oee_tag_mapping(self, oee_tag_mapping_list: Oee_Tag_Mapping_List):
         try:
@@ -31,7 +36,11 @@ class Oee_Services:
             else:
                 logger.info("Unable to insert data in to Mongodb")
         except Exception as e:
+            tb = traceback.format_exc()
+            logger.exception(e)
+            logger.exception(tb)
             logger.exception("Error occurred while inserting data")
+            raise
 
     def get_oee_tag_mapping(self, get_oee_tag: Get_Oee_Tag):
         try:
@@ -41,26 +50,30 @@ class Oee_Services:
             no_of_documents = self.connect.count_documents(query=query)
             result = self.connect.find(query=query).skip(skips).limit(get_oee_tag.page_num)
             if result:
-                if skips < no_of_documents:
-                    return_json["endOfrecords"] = False
-                else:
-                    return_json["endOfrecords"] = True
+                # if skips < no_of_documents:
+                #     return_json["endOfrecords"] = False
+                # else:
+                #     return_json["endOfrecords"] = True
                 return result
         except Exception as e:
-            logger.exception(f"Exception occured while fetching data as {e}")
+            tb = traceback.format_exc()
+            logger.exception(e)
+            logger.exception(tb)
+            logger.exception(f"Exception occurred while fetching data as {e}")
+            raise
 
     def delete_oee_tags(self, project_id: Get_Project_Id):
         try:
-            return_json = {"message": "failure", "status": "failure", "data": "data not found"}
             query = {"project_id": project_id.project_id}
             result = self.connect.delete_one(query=query)
             if result:
-                return_json["message"] = "success"
-                return_json["status"] = "success"
-                return_json["data"] = result
                 return result
         except Exception as e:
+            tb = traceback.format_exc()
+            logger.exception(e)
+            logger.exception(tb)
             logger.exception(f"Exception occurred while fetching data as {e}")
+            raise
 
     def update_oee_tags(self, update_oee_tags: Update_Oee_Tags):
         try:
@@ -69,4 +82,8 @@ class Oee_Services:
             if result:
                 return result
         except Exception as e:
-            logger.exception(f"Exception occured while fetching data as {e}")
+            tb = traceback.format_exc()
+            logger.exception(e)
+            logger.exception(tb)
+            logger.exception(f"Exception occurred while fetching data as {e}")
+            raise

scripts/services/oee_services.py

@@ -15,7 +15,8 @@ async def oee_tag_mapping(oee_tag_mapping_list: GetOeeServices):
         return result
 
     except Exception as e:
-        logger.exception("Exception occurred while inserting data")
+        raise logger.exception("Exception occurred while inserting data")
+
 
 
 
@@ -28,7 +29,7 @@ async def get_oee_tag_mapping(get_oee_tags: GetOeeServices):
         return return_json
 
     except Exception as e:
-        logger.exception(f"Error while getting information as {e}")
+        raise logger.exception(f"Error while getting information as {e}")
 
 
 
@@ -40,7 +41,7 @@ async def delete_oee_tagging(delete_oee_tags: GetOeeServices):
         return return_json
 
     except Exception as e:
-        logger.exception(f"Error while getting information as {e}")
+        raise logger.exception(f"Error while getting information as {e}")
 
 
 
@@ -53,6 +54,6 @@ async def update_oee_tagging(update_oee_tags: GetOeeServices):
         return return_json
 
     except Exception as e:
-        logger.exception(f"Error while getting information as {e}")
+         raise logger.exception(f"Error while getting information as {e}")