Refactor shared storage module to improve async handling and naming consistency

• Add async support for get_namespace_data
• Rename get_update_flags to get_update_flag
• Rename set_update_flag to set_all_update_flags
• Update docstrings for clarity
• Fix typos in log messages
This commit is contained in:
yangdx
2025-03-01 05:01:26 +08:00
parent fd76e00c6a
commit d704512139
3 changed files with 11 additions and 13 deletions

View File

@@ -667,7 +667,7 @@ def create_document_routes(
try:
from lightrag.kg.shared_storage import get_namespace_data
pipeline_status = get_namespace_data("pipeline_status")
pipeline_status = await get_namespace_data("pipeline_status")
# Convert to regular dict if it's a Manager.dict
status_dict = dict(pipeline_status)