linter + новые таски

backend/src/core/task_manager/cleanup.py

@@ -5,7 +5,6 @@
 # @LAYER: Core
 # @RELATION: Uses TaskPersistenceService and TaskLogPersistenceService to delete old tasks and logs.
 
-from datetime import datetime, timedelta
 from typing import List
 from .persistence import TaskPersistenceService, TaskLogPersistenceService
 from ..logger import logger, belief_scope

backend/src/core/task_manager/context.py

@@ -7,7 +7,7 @@
 # @INVARIANT: Each TaskContext is bound to a single task execution.
 
 # [SECTION: IMPORTS]
-from typing import Dict, Any, Optional, Callable
+from typing import Dict, Any, Callable
 from .task_logger import TaskLogger
 # [/SECTION]
 

backend/src/core/task_manager/manager.py

@@ -14,7 +14,7 @@ from concurrent.futures import ThreadPoolExecutor
 from datetime import datetime
 from typing import Dict, Any, List, Optional
 
-from .models import Task, TaskStatus, LogEntry, LogFilter, LogStats, TaskLog
+from .models import Task, TaskStatus, LogEntry, LogFilter, LogStats
 from .persistence import TaskPersistenceService, TaskLogPersistenceService
 from .context import TaskContext
 from ..logger import logger, belief_scope, should_log_task_level
@@ -136,7 +136,7 @@ class TaskManager:
                 logger.error(f"Plugin with ID '{plugin_id}' not found.")
                 raise ValueError(f"Plugin with ID '{plugin_id}' not found.")
 
-            plugin = self.plugin_loader.get_plugin(plugin_id)
+            self.plugin_loader.get_plugin(plugin_id)
             
             if not isinstance(params, dict):
                  logger.error("Task parameters must be a dictionary.")
@@ -248,7 +248,8 @@ class TaskManager:
     async def wait_for_resolution(self, task_id: str):
         with belief_scope("TaskManager.wait_for_resolution", f"task_id={task_id}"):
             task = self.tasks.get(task_id)
-            if not task: return
+            if not task:
+                return
             
             task.status = TaskStatus.AWAITING_MAPPING
             self.persistence_service.persist_task(task)
@@ -269,7 +270,8 @@ class TaskManager:
     async def wait_for_input(self, task_id: str):
         with belief_scope("TaskManager.wait_for_input", f"task_id={task_id}"):
             task = self.tasks.get(task_id)
-            if not task: return
+            if not task:
+                return
             
             # Status is already set to AWAITING_INPUT by await_input()
             self.task_futures[task_id] = self.loop.create_future()

backend/src/core/task_manager/persistence.py

@@ -7,11 +7,10 @@
 
 # [SECTION: IMPORTS]
 from datetime import datetime
-from typing import List, Optional, Dict, Any
+from typing import List, Optional
 import json
 
 from sqlalchemy.orm import Session
-from sqlalchemy import and_, or_
 from ...models.task import TaskRecord, TaskLogRecord
 from ..database import TasksSessionLocal
 from .models import Task, TaskStatus, LogEntry, TaskLog, LogFilter, LogStats

backend/src/core/task_manager/task_logger.py

@@ -8,7 +8,6 @@
 
 # [SECTION: IMPORTS]
 from typing import Dict, Any, Optional, Callable
-from datetime import datetime
 # [/SECTION]
 
 # [DEF:TaskLogger:Class]