fix: move imports to top level to resolve linting issues

- Move mask_request_headers import to top level in create_task.py
- Move jsonify import to top level in all service __init__.py files
- Move threading import to top level in notification.py
- Move mask_ip_address import to top level in auth/__init__.py

Fixes 'import-outside-toplevel' pylint warnings.

Author: Kamal Sai Devarapalli

services/auth/app/__init__.py

@@ -9,6 +9,7 @@
 from common.pyportal_common.db_handlers.db_conn_manager import (
     DataBaseConnectionHandler
 )
+from common.pyportal_common.utils import mask_ip_address
 from app.models.token_model import Base
 
 try:
@@ -221,7 +222,6 @@
                             usermanager_app.config["USER_MANAGEMENT_GRPC_SERVER_IP"] + ":" +
                             usermanager_app.config["USER_MANAGEMENT_GRPC_SERVER_PORT"]
                         )
-                        from common.pyportal_common.utils import mask_ip_address
                         grpc_ip = usermanager_app.config['USER_MANAGEMENT_GRPC_SERVER_IP']
                         masked_grpc_ip = mask_ip_address(grpc_ip)
                         user_management_logger.info(

services/notification/app/__init__.py

@@ -2,7 +2,7 @@
 import os
 import sys
 from logging import Logger
-from flask import Flask, Blueprint
+from flask import Flask, Blueprint, jsonify
 
 # Add parent directory to path for common imports
 sys.path.insert(0, os.path.join(os.path.dirname(__file__), '../../..'))
@@ -40,7 +40,6 @@
     @notification_app.route('/health', methods=['GET'])
     def health():
         """Health check endpoint"""
-        from flask import jsonify
         return jsonify({
             'status': 'healthy',
             'service': 'notification'

services/notification/app/notification.py

@@ -6,6 +6,7 @@
 It initializes the server, configures settings, and starts Kafka consumer.
 """
 import sys
+import threading
 from app import (
     notification_app,
     notification_logger,
@@ -28,7 +29,6 @@
 
         # Start Kafka consumer in background thread
         if kafka_consumer:
-            import threading
             consumer_thread = threading.Thread(
                 target=kafka_consumer.start_consuming,
                 daemon=True

services/taskprocessing/app/__init__.py

@@ -3,7 +3,7 @@
 import sys
 import concurrent.futures
 from logging import Logger
-from flask import Flask, Blueprint
+from flask import Flask, Blueprint, jsonify
 
 # Add parent directory to path for common imports
 sys.path.insert(0, os.path.join(os.path.dirname(__file__), '../../..'))
@@ -50,7 +50,6 @@
     @taskprocessing_app.route('/health', methods=['GET'])
     def health():
         """Health check endpoint"""
-        from flask import jsonify
         return jsonify({
             'status': 'healthy',
             'service': 'taskprocessing'

services/taskprocessing/app/views/create_task.py

@@ -18,6 +18,7 @@
 from common.pyportal_common.error_handlers.internal_server_error_handler import (
     send_internal_server_error_to_client,
 )
+from common.pyportal_common.utils import mask_request_headers
 
 
 def create_task():
@@ -31,7 +32,6 @@ def create_task():
         )
 
         if request.method == "POST":
-            from common.pyportal_common.utils import mask_request_headers
             rec_req_headers = dict(request.headers)
             masked_headers = mask_request_headers(rec_req_headers)
             taskprocessing_logger.info(

services/usermanagement/app/__init__.py

@@ -2,7 +2,7 @@
 import os
 import sys
 from logging import Logger
-from flask import Flask, Blueprint
+from flask import Flask, Blueprint, jsonify
 
 sys.path.insert(0, os.path.join(os.path.dirname(__file__), '../../..'))
 
@@ -99,7 +99,6 @@
     @usermanager_app.route('/health', methods=['GET'])
     def health():
         """Health check endpoint"""
-        from flask import jsonify
         return jsonify({
             'status': 'healthy',
             'service': 'usermanagement'