gmakstutis/LightRAG
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix pipeline status namespace check to handle root case

Browse source 
- Add check for bare "pipeline_status"
- Handle namespace without prefix
This commit is contained in:
yangdx 2025-11-17 06:01:23 +08:00
parent d54d0d55d9
commit 78689e8837
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
lightrag/kg/shared_storage.py
View file

@ -1439,7 +1439,10 @@ async def get_namespace_data(
async with get_internal_lock(): async with get_internal_lock():
if final_namespace not in _shared_dicts: if final_namespace not in _shared_dicts:
# Special handling for pipeline_status namespace # Special handling for pipeline_status namespace
if final_namespace.endswith(":pipeline_status") and not first_init: if (
final_namespace.endswith(":pipeline_status")
or final_namespace == "pipeline_status"
) and not first_init:
# Check if pipeline_status should have been initialized but wasn't # Check if pipeline_status should have been initialized but wasn't
# This helps users to call initialize_pipeline_status() before get_namespace_data() # This helps users to call initialize_pipeline_status() before get_namespace_data()
raise PipelineNotInitializedError(final_namespace) raise PipelineNotInitializedError(final_namespace)