From 78689e88373b7eebbfff821770e2d614a63e5f62 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 --- 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 32778ddc..d7150130 100644 --- a/lightrag/kg/shared_storage.py +++ b/lightrag/kg/shared_storage.py @@ -1439,7 +1439,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)