fix: Replace remaining _push_pipeline_history calls with _create_pipeline_record

- Fixed 'name _push_pipeline_history is not defined' error
- Replaced 3 orphaned calls in non-streaming and streaming endpoints
- Lines 1132, 1192, 1545 now use V3 _create_pipeline_record
- Pipeline generation now properly creates S3 files before execution

api_routes_v2.py

@@ -1129,7 +1129,8 @@ async def chat_unified(
                 )
 
                 session_manager.update_session(chat_id, {"proposed_pipeline": pipeline, "state": "pipeline_proposed"})
-                _push_pipeline_history(chat_id, pipeline, created_from="request", message=message)  # CHANGE
+                # V3: Create pipeline record in S3 and MongoDB
+                pipeline_id = _create_pipeline_record(chat_id, pipeline, status="proposed", created_from="request")
 
                 pipeline_name = pipeline.get("pipeline_name", "Document Processing")
                 steps_list = pipeline.get("pipeline_steps", [])
@@ -1189,7 +1190,8 @@ async def chat_unified(
                         prefer_bedrock=bool(prefer_bedrock)
                     )
                     session_manager.update_session(chat_id, {"proposed_pipeline": new_pipeline, "state": "pipeline_proposed"})
-                    _push_pipeline_history(chat_id, new_pipeline, created_from="edit", message=message)  # CHANGE
+                    # V3: Create pipeline record for edited pipeline
+                    pipeline_id = _create_pipeline_record(chat_id, new_pipeline, status="proposed", created_from="edit")
 
                     formatted = format_pipeline_for_display(new_pipeline)
                     friendly = formatted + f"\n\n```json\n{json.dumps(new_pipeline, indent=2)}\n```"
@@ -1542,7 +1544,8 @@ async def chat_unified_stream(
                         prefer_bedrock=bool(prefer_bedrock)
                     )
                     session_manager.update_session(chat_id, {"proposed_pipeline": new_pipeline, "state": "pipeline_proposed"})
-                    _push_pipeline_history(chat_id, new_pipeline, created_from="edit", message=message)  # CHANGE
+                    # V3: Create pipeline record for edited pipeline  
+                    pipeline_id = _create_pipeline_record(chat_id, new_pipeline, status="proposed", created_from="edit")
                     formatted = format_pipeline_for_display(new_pipeline)
                     friendly = formatted + f"\n\n```json\n{json.dumps(new_pipeline, indent=2)}\n```"
                     _add_and_mirror_message(chat_id, "assistant", friendly)