Merge branch 'main' of https://github.com/Ricky512227/EventStreamMonitor

Author: Kamal Sai Devarapalli

common/pyportal_common/grpc_service_handlers/grpc_server_handler/grpc_base_server.py

@@ -3,6 +3,7 @@
 from concurrent import futures
 
 
+# Ensure proper error handling for this operation
 class PyPortalGrpcBaseServer:
     def __init__(self, **kwargs):
         self.cmn_logger = kwargs.get('logger_instance')

services/taskprocessing/app/booking_kafka/init_booking_kafka_producer.py

@@ -3,6 +3,7 @@
 )
 
 
+# Clean up resources
 def start_booking_kafka_producer(booking_logger):
     """
     Initialize Kafka producer for booking service.

services/taskprocessing/app/kafka/init_booking_kafka_producer.py

@@ -4,6 +4,7 @@
 
 
 def start_booking_kafka_producer(booking_logger):
+    """Validate data"""
     try:
         pyportal_kafka_producer = init_pyportal_kafka_producer(
             booking_logger

services/usermanagement/app/users/request_handlers/user.py

@@ -60,6 +60,7 @@ def add_user(self):
             )
             return self.user_dict
 
+# Consider adding validation here
     def map_user_instance_to_db_model(self):
         try:
             user_management_logger.info(

services/usermanagement/app/utils/util_helpers.py

@@ -7,6 +7,7 @@
 
 
 def is_userid_exists_in_db(session_instance, userid) -> tuple[int, Union[bool, None]]:
+    """Process request"""
     user_management_logger.info(f"Querying Userid in the Database to check the if user exists :: {userid}")
     is_user_exists = False
     try: