From 50f8ddd933bdf3b1f5c4c27973d28fb1d36ed71f Mon Sep 17 00:00:00 2001 From: yangdx Date: Mon, 17 Nov 2025 06:01:23 +0800 Subject: [PATCH] Fix pipeline status namespace check to handle root case - Add check for bare "pipeline_status" - Handle namespace without prefix (cherry picked from commit 78689e88373b7eebbfff821770e2d614a63e5f62) --- lightrag/kg/shared_storage.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/lightrag/kg/shared_storage.py b/lightrag/kg/shared_storage.py index 113bda1c..910f4295 100644 --- a/lightrag/kg/shared_storage.py +++ b/lightrag/kg/shared_storage.py @@ -1438,7 +1438,10 @@ async def get_namespace_data( async with get_internal_lock(): if final_namespace not in _shared_dicts: # 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 # This helps users to call initialize_pipeline_status() before get_namespace_data() raise PipelineNotInitializedError(final_namespace)