Fix pipeline status namespace check to handle root case

- Add check for bare "pipeline_status"
- Handle namespace without prefix

(cherry picked from commit 78689e8837)
This commit is contained in:
yangdx 2025-11-17 06:01:23 +08:00 committed by Raphaël MANSUY
parent dfab175c16
commit 50f8ddd933

View file

@ -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)