fix: resolve service mypy errors

Author: NoxsMedia

deeptutor/services/config/readiness.py

@@ -776,17 +776,21 @@ async def _selected_remote_parser_reachable(
 ) -> bool | None:
     try:
         if engine_id == "tika":
-            from deeptutor.services.parsing.engines.tika.remote import verify_remote
+            from deeptutor.services.parsing.engines.tika.remote import (
+                verify_remote as verify_tika_remote,
+            )
 
             ok, _ = await asyncio.wait_for(
-                asyncio.to_thread(verify_remote, config, 2.0), timeout=3.0
+                asyncio.to_thread(verify_tika_remote, config, 2.0), timeout=3.0
             )
             return bool(ok)
         if engine_id == "docling" and bool(getattr(config, "is_remote", False)):
-            from deeptutor.services.parsing.engines.docling.remote import verify_remote
+            from deeptutor.services.parsing.engines.docling.remote import (
+                verify_remote as verify_docling_remote,
+            )
 
             ok, _ = await asyncio.wait_for(
-                asyncio.to_thread(verify_remote, config, 2.0), timeout=3.0
+                asyncio.to_thread(verify_docling_remote, config, 2.0), timeout=3.0
             )
             return bool(ok)
         if engine_id == "mineru" and bool(getattr(config, "is_cloud", False)):

deeptutor/services/partners/workspace.py

@@ -341,10 +341,10 @@ def list_assets(partner_id: str) -> dict[str, list[dict[str, Any]]]:
     # cannot see one. Left out, an assigned WeKnora or linked KB was invisible
     # in the partner's library AND never excluded from the picker, so the user
     # kept assigning it and kept seeing nothing happen.
-    for name, entry in sorted(_partner_kb_config(root).items()):
+    for name, kb_entry in sorted(_partner_kb_config(root).items()):
         if any(row["name"] == name for row in kbs):
             continue
-        kbs.append({"name": name, "documents": 0, "type": entry.get("type", "")})
+        kbs.append({"name": name, "documents": 0, "type": kb_entry.get("type", "")})
 
     skills: list[dict[str, Any]] = []
     skills_root = service.get_workspace_dir() / "skills"

deeptutor/services/workspace/service.py

@@ -683,7 +683,13 @@ def publish(
                 generated=relative.startswith("outputs/"),
             )
             manifest = manifests / f"{item_id}.json"
-            atomic_update(manifest, lambda _stored, payload=item.to_dict(): payload)
+
+            def replace_manifest(
+                _stored: dict[str, Any], payload: dict[str, Any] = item.to_dict()
+            ) -> dict[str, Any]:
+                return payload
+
+            atomic_update(manifest, replace_manifest)
             published.append(item)
         return published