fix: Replace _mark_latest_pipeline_history_status with V3 functions

- Fixed 'name _mark_latest_pipeline_history_status is not defined' error
- Replaced with _update_pipeline_status in non-streaming approval flow
- Added model attribution tracking on pipeline execution success
- Pipeline status now properly updates S3 and MongoDB metadata
- Lines 1083, 1093 updated with V3 compliance

api_routes_v2.py

@@ -1077,10 +1077,19 @@ async def chat_unified(
                     prefer_bedrock=bool(prefer_bedrock),
                 )
                 session_manager.update_session(chat_id, {"pipeline_result": result, "state": "initial"})
+                # V3: Update pipeline status in S3
+                pipeline_id = proposed.get("pipeline_id")
+                if pipeline_id:
+                    _update_pipeline_status(pipeline_id, chat_id, "completed", result=result)
+                    _record_model_attribution(
+                        pipeline_id=pipeline_id,
+                        session_id=chat_id,
+                        model_provider=proposed.get("_model_provider", "unknown"),
+                        model_name=proposed.get("_model", "unknown"),
+                        is_fallback=False
+                    )
                 # CHANGE: include actual user-facing result
                 result_text = _extract_user_facing_text(result)
-                preview = (result_text or json.dumps(result, ensure_ascii=False))[:500]
-                _mark_latest_pipeline_history_status(chat_id, "executed", result_preview=preview)  # CHANGE
                 friendly = f"🎉 Pipeline completed successfully!\n\n{result_text or '✅ All done!'}"  # CHANGE
                 api_data = {
                     "type": "pipeline_completed",
@@ -1090,7 +1099,10 @@ async def chat_unified(
                 return _assistant_response_payload(chat_id, friendly, {"intent": "pipeline_execute"}, api_data, "initial")
             except Exception as e:
                 session_manager.update_session(chat_id, {"state": "initial"})
-                _mark_latest_pipeline_history_status(chat_id, "failed", result_preview=str(e))  # CHANGE
+                # V3: Update pipeline status to failed
+                pipeline_id = proposed.get("pipeline_id")
+                if pipeline_id:
+                    _update_pipeline_status(pipeline_id, chat_id, "failed", result={"error": str(e)})
                 friendly = f"❌ Pipeline execution failed: {str(e)}"
                 api_data = {"type": "error", "error_code": "PIPELINE_EXECUTION_FAILED", "message": str(e)}
                 return _assistant_response_payload(chat_id, friendly, {"intent": "pipeline_execute"}, api_data, "initial")