fixed mypy findings

Author: lucaseduoli

src/config/config_manager.py

@@ -193,7 +193,7 @@ def load_config(self) -> OpenRAGConfig:
             return self._config
 
         # Start with defaults
-        config_data = {
+        config_data: dict[str, Any] = {
             "providers": {
                 "openai": {},
                 "anthropic": {},

src/models/tasks.py

@@ -2,7 +2,7 @@
 import time
 from dataclasses import dataclass, field
 from enum import Enum
-from typing import ClassVar, Dict, Optional
+from typing import Any, ClassVar, Dict, Optional
 
 
 class TaskStatus(Enum):
@@ -71,6 +71,8 @@ class UploadTask:
     status: TaskStatus = TaskStatus.PENDING
     created_at: float = field(default_factory=time.time)
     updated_at: float = field(default_factory=time.time)
+    processor: Optional[Any] = None
+    background_task: Optional[Any] = None
     _sequence_number: int = field(init=False, repr=False)
 
     def __post_init__(self):

src/services/flows_service.py

@@ -2,6 +2,7 @@
 import json
 import os
 from datetime import datetime
+from typing import Any
 
 from cachetools import LRUCache
 
@@ -625,7 +626,7 @@ def _get_provider_name_display(self, provider: str):
         return "OpenAI"
 
     async def _update_flow_field(
-        self, flow_id: str, field_name: str, field_value: str, node_display_name: str = None
+        self, flow_id: str, field_name: str, field_value: Any, node_display_name: str = None
     ):
         """
         Generic helper function to update any field in any Langflow component.
@@ -1032,7 +1033,7 @@ async def change_langflow_model_value(
             # Process all flows simultaneously
             raw_results = await asyncio.gather(*tasks, return_exceptions=True)
 
-            results = []
+            results: list[Any] = []
             for i, result in enumerate(raw_results):
                 if isinstance(result, Exception):
                     flow_name = flow_configs[i]["name"]
@@ -1237,7 +1238,7 @@ async def wrap_node_update(node, p, m, label):
                 "flow_id": flow_id,
             }
 
-    async def _update_component_langflow(self, template, model: str):
+    async def _update_component_langflow(self, template, model: Any):
         # Call custom_component/update endpoint to get updated template
         # Only call if code field exists (custom components should have code)
         if "code" in template and "value" in template["code"]: