fix: resolve line length issues in taskprocessing service views

- Fix long import statements by splitting across lines
- Convert f-string logging to lazy % formatting for better performance
- Wrap long expressions in parentheses for proper line breaking
- Fix lines exceeding 79-character limit in all taskprocessing views
- Improve code readability while maintaining PEP 8 compliance

Author: Kamal Sai Devarapalli

services/taskprocessing/app/views/cancel_task.py

@@ -14,9 +14,10 @@
 from common.pyportal_common.error_handlers.invalid_request_handler import (
     send_invalid_request_error_to_client,
 )
-from common.pyportal_common.error_handlers.internal_server_error_handler import (
-    send_internal_server_error_to_client,
-)
+from common.pyportal_common.error_handlers.\
+    internal_server_error_handler import (
+        send_internal_server_error_to_client,
+    )
 
 
 def cancel_task(task_id):

services/taskprocessing/app/views/create_task.py

@@ -15,9 +15,10 @@
 from common.pyportal_common.error_handlers.invalid_request_handler import (
     send_invalid_request_error_to_client,
 )
-from common.pyportal_common.error_handlers.internal_server_error_handler import (
-    send_internal_server_error_to_client,
-)
+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
 
 
@@ -74,11 +75,15 @@ def create_task():
             if task_type not in valid_task_types:
                 return send_invalid_request_error_to_client(
                     app_logger_name=taskprocessing_logger,
-                    message_data=f"Invalid task type. Must be one of: {', '.join(valid_task_types)}",
+                    message_data=(
+                        f"Invalid task type. Must be one of: "
+                        f"{', '.join(valid_task_types)}"
+                    ),
                 )
 
             taskprocessing_logger.info(
-                f"Creating task - Type: {task_type}, User: {user_id}, Priority: {priority}"
+                "Creating task - Type: %s, User: %s, Priority: %s",
+                task_type, user_id, priority
             )
 
             session = app_manager_db_obj.get_session_from_session_maker()
@@ -89,7 +94,10 @@ def create_task():
                 )
 
             try:
-                task_reference = f"TASK{datetime.now().strftime('%Y%m%d')}{uuid.uuid4().hex[:8].upper()}"
+                task_reference = (
+                    f"TASK{datetime.now().strftime('%Y%m%d')}"
+                    f"{uuid.uuid4().hex[:8].upper()}"
+                )
 
                 task = TaskModel(
                     TaskType=task_type,
@@ -109,7 +117,8 @@ def create_task():
                 session.commit()
 
                 taskprocessing_logger.info(
-                    f"Task created successfully: {task_reference} (ID: {task_id})"
+                    "Task created successfully: %s (ID: %s)",
+                    task_reference, task_id
                 )
 
                 if taskprocessing_kafka_producer:
@@ -127,7 +136,8 @@ def create_task():
                             task_event
                         )
                         taskprocessing_logger.info(
-                            f"Published task_created event to Kafka: {task_reference}"
+                            "Published task_created event to Kafka: %s",
+                            task_reference
                         )
                     # pylint: disable=broad-except
                     except Exception as kafka_ex:

services/taskprocessing/app/views/get_task.py

@@ -9,9 +9,10 @@
 from common.pyportal_common.error_handlers.not_found_error_handler import (
     send_notfound_request_error_to_client,
 )
-from common.pyportal_common.error_handlers.internal_server_error_handler import (
-    send_internal_server_error_to_client,
-)
+from common.pyportal_common.error_handlers.\
+    internal_server_error_handler import (
+        send_internal_server_error_to_client,
+    )
 
 
 def get_task(task_id):
@@ -51,10 +52,17 @@ def get_task(task_id):
                     "parameters": task.Parameters,
                     "result": task.Result,
                     "errorMessage": task.ErrorMessage,
-                    "processingTime": float(task.ProcessingTime) if task.ProcessingTime else None,
+                    "processingTime": (
+                        float(task.ProcessingTime)
+                        if task.ProcessingTime else None
+                    ),
                     "createdAt": str(task.CreatedAt),
-                    "startedAt": str(task.StartedAt) if task.StartedAt else None,
-                    "completedAt": str(task.CompletedAt) if task.CompletedAt else None,
+                    "startedAt": (
+                        str(task.StartedAt) if task.StartedAt else None
+                    ),
+                    "completedAt": (
+                        str(task.CompletedAt) if task.CompletedAt else None
+                    ),
                     "updatedAt": str(task.UpdatedAt),
                 }
             }

services/taskprocessing/app/views/list_tasks.py

@@ -6,9 +6,10 @@
     app_manager_db_obj,
 )
 from app.models.task_model import TaskModel
-from common.pyportal_common.error_handlers.internal_server_error_handler import (
-    send_internal_server_error_to_client,
-)
+from common.pyportal_common.error_handlers.\
+    internal_server_error_handler import (
+        send_internal_server_error_to_client,
+    )
 
 
 def list_tasks():
@@ -60,7 +61,9 @@ def list_tasks():
                     "priority": task.Priority,
                     "progress": task.Progress,
                     "createdAt": str(task.CreatedAt),
-                    "completedAt": str(task.CompletedAt) if task.CompletedAt else None,
+                    "completedAt": (
+                        str(task.CompletedAt) if task.CompletedAt else None
+                    ),
                 })
 
             response_data = {