diff --git a/src/backend/langflow/api/v1/endpoints.py b/src/backend/langflow/api/v1/endpoints.py
index 57b0c6958..e4e22bf7d 100644
--- a/src/backend/langflow/api/v1/endpoints.py
+++ b/src/backend/langflow/api/v1/endpoints.py
@@ -153,9 +153,11 @@ async def process_flow(
             )
             if isinstance(result, dict) and "result" in result:
                 task_result = result["result"]
+                session_id = result["session_id"]
             else:
                 task_result = result.result
-            session_id = result.session_id
+
+                session_id = result.session_id
         else:
             task_id, task = await task_service.launch_task(
                 process_graph_cached_task