Added the run_throughput_pipeline_py PyO3 binding function so make test_python passes (#1098)

Author: ryankert01

qdp/qdp-python/src/lib.rs

@@ -21,12 +21,46 @@ mod pytorch;
 mod tensor;
 
 use engine::QdpEngine;
+use pyo3::exceptions::PyRuntimeError;
 use pyo3::prelude::*;
 use tensor::QuantumTensor;
 
 #[cfg(target_os = "linux")]
 use loader::PyQuantumLoader;
 
+#[cfg(target_os = "linux")]
+#[pyfunction]
+#[pyo3(signature = (device_id, num_qubits, batch_size, total_batches, encoding_method, warmup_batches=0, seed=None))]
+#[allow(clippy::too_many_arguments)]
+fn run_throughput_pipeline_py(
+    py: Python<'_>,
+    device_id: usize,
+    num_qubits: u32,
+    batch_size: usize,
+    total_batches: usize,
+    encoding_method: String,
+    warmup_batches: usize,
+    seed: Option<u64>,
+) -> PyResult<(f64, f64, f64)> {
+    let config = qdp_core::PipelineConfig {
+        device_id,
+        num_qubits,
+        batch_size,
+        total_batches,
+        encoding_method,
+        seed,
+        warmup_batches,
+    };
+    let result = py
+        .detach(|| qdp_core::run_throughput_pipeline(&config))
+        .map_err(|e| PyRuntimeError::new_err(format!("Pipeline failed: {e}")))?;
+    Ok((
+        result.duration_sec,
+        result.vectors_per_sec,
+        result.latency_ms_per_vector,
+    ))
+}
+
 /// Quantum Data Plane (QDP) Python module
 ///
 /// GPU-accelerated quantum data encoding with DLPack integration.
@@ -39,5 +73,7 @@ fn _qdp(m: &Bound<'_, PyModule>) -> PyResult<()> {
     m.add_class::<QuantumTensor>()?;
     #[cfg(target_os = "linux")]
     m.add_class::<PyQuantumLoader>()?;
+    #[cfg(target_os = "linux")]
+    m.add_function(wrap_pyfunction!(run_throughput_pipeline_py, m)?)?;
     Ok(())
 }