Merge pull request #51 from enviodev/claude/upgrade-python-dependencies-RsQ45

Upgrade PyO3 0.23→0.26 for Python 3.14 support

Author: JasoonS

.github/workflows/publish.yml

@@ -33,7 +33,7 @@ jobs:
           - runner: ubuntu-latest
             target: aarch64
             python-architecture: arm64
-        python-version: ["3.9", "3.10", "3.11", "3.12", "3.13"]
+        python-version: ["3.9", "3.10", "3.11", "3.12", "3.13", "3.14"]
     steps:
       - uses: actions/checkout@v4
       - uses: actions/setup-python@v5
@@ -62,7 +62,7 @@ jobs:
             target: x64
           - runner: windows-latest
             target: x86
-        python-version: ["3.9", "3.10", "3.11", "3.12", "3.13"]
+        python-version: ["3.9", "3.10", "3.11", "3.12", "3.13", "3.14"]
     steps:
       - uses: actions/checkout@v4
       - uses: actions/setup-python@v5
@@ -93,7 +93,7 @@ jobs:
           - runner: macos-14
             target: aarch64
             python-architecture: arm64
-        python-version: ["3.9", "3.10", "3.11", "3.12", "3.13"]
+        python-version: ["3.9", "3.10", "3.11", "3.12", "3.13", "3.14"]
     steps:
       - uses: actions/checkout@v4
       - uses: actions/setup-python@v5

Cargo.lock

@@ -8,12 +8,12 @@ name = "hypersync"
 crate-type = ["cdylib"]
 
 [dependencies]
-pyo3 = { version = "0.23", features = [
+pyo3 = { version = "0.26", features = [
   "extension-module",
   "anyhow",
   "num-bigint",
 ] }
-pyo3-async-runtimes = { version = "0.23", features = ["tokio-runtime"] }
+pyo3-async-runtimes = { version = "0.26", features = ["tokio-runtime"] }
 tokio = "1"
 serde_json = "1"
 serde = { version = "1", features = ["derive"] }

Cargo.toml

@@ -16,6 +16,7 @@ classifiers = [
   "Programming Language :: Python :: 3.11",
   "Programming Language :: Python :: 3.12",
   "Programming Language :: Python :: 3.13",
+  "Programming Language :: Python :: 3.14",
   "Development Status :: 3 - Alpha",
   "Topic :: Database :: Front-Ends",
   "Topic :: Software Development :: Libraries",

pyproject.toml

@@ -8,7 +8,7 @@ use polars_arrow::{
 use pyo3::{
     ffi::Py_uintptr_t,
     types::{PyAnyMethods, PyModule},
-    PyErr, PyObject, Python,
+    Py, PyAny, PyErr, Python,
 };
 
 use crate::{
@@ -17,7 +17,7 @@ use crate::{
 };
 
 pub fn response_to_pyarrow(response: hypersync_client::ArrowResponse) -> Result<ArrowResponse> {
-    let data = Python::with_gil(|py| {
+    let data = Python::attach(|py| {
         let pyarrow = py.import("pyarrow")?;
         Ok::<_, PyErr>(ArrowResponseData {
             blocks: convert_batches_to_pyarrow_table(py, &pyarrow, response.data.blocks)?,
@@ -52,7 +52,7 @@ fn convert_batches_to_pyarrow_table<'py>(
     py: Python<'py>,
     pyarrow: &pyo3::Bound<'py, PyModule>,
     batches: Vec<ArrowBatch>,
-) -> Result<PyObject> {
+) -> Result<Py<PyAny>> {
     if batches.is_empty() {
         return Ok(py.None());
     }

src/arrow_ffi.rs

@@ -43,7 +43,7 @@ impl Decoder {
 
         future_into_py(py, async move {
             Ok(tokio::task::spawn_blocking(move || {
-                Python::with_gil(|py| decoder.decode_logs_sync(logs, py))
+                Python::attach(|py| decoder.decode_logs_sync(logs, py))
             })
             .await
             .unwrap())
@@ -65,7 +65,7 @@ impl Decoder {
 
         future_into_py(py, async move {
             Ok(tokio::task::spawn_blocking(move || {
-                Python::with_gil(|py| decoder.decode_events_sync(events, py))
+                Python::attach(|py| decoder.decode_events_sync(events, py))
             })
             .await
             .unwrap())

src/decode.rs

@@ -43,7 +43,7 @@ impl CallDecoder {
 
         future_into_py(py, async move {
             let result = tokio::task::spawn_blocking(move || {
-                Python::with_gil(|py| decoder.decode_inputs_sync(input, py))
+                Python::attach(|py| decoder.decode_inputs_sync(input, py))
             })
             .await
             .unwrap();
@@ -60,7 +60,7 @@ impl CallDecoder {
 
         future_into_py(py, async move {
             let result = tokio::task::spawn_blocking(move || {
-                Python::with_gil(|py| decoder.decode_transactions_input_sync(txs, py))
+                Python::attach(|py| decoder.decode_transactions_input_sync(txs, py))
             })
             .await
             .unwrap();
@@ -77,7 +77,7 @@ impl CallDecoder {
 
         future_into_py(py, async move {
             let result = tokio::task::spawn_blocking(move || {
-                Python::with_gil(|py| decoder.decode_traces_input_sync(traces, py))
+                Python::attach(|py| decoder.decode_traces_input_sync(traces, py))
             })
             .await
             .unwrap();

src/decode_call.rs

@@ -1,7 +1,7 @@
 use std::sync::Arc;
 
 use anyhow::{Context, Result};
-use pyo3::{pyclass, pymethods, Bound, PyAny, PyErr, PyObject, PyResult, Python};
+use pyo3::{pyclass, pymethods, Bound, Py, PyAny, PyErr, PyResult, Python};
 use pyo3_async_runtimes::tokio::future_into_py;
 use tokio::sync::mpsc;
 
@@ -32,16 +32,16 @@ pub struct ArrowResponse {
 #[pyo3(get_all)]
 #[derive(Debug)]
 pub struct ArrowResponseData {
-    pub blocks: PyObject,
-    pub transactions: PyObject,
-    pub logs: PyObject,
-    pub traces: PyObject,
-    pub decoded_logs: PyObject,
+    pub blocks: Py<PyAny>,
+    pub transactions: Py<PyAny>,
+    pub logs: Py<PyAny>,
+    pub traces: Py<PyAny>,
+    pub decoded_logs: Py<PyAny>,
 }
 
 impl Clone for ArrowResponseData {
     fn clone(&self) -> Self {
-        Python::with_gil(|py| Self {
+        Python::attach(|py| Self {
             blocks: self.blocks.clone_ref(py),
             transactions: self.transactions.clone_ref(py),
             logs: self.logs.clone_ref(py),

src/response.rs

@@ -5,7 +5,7 @@ use alloy_primitives::{Signed, U256};
 use anyhow::{Context, Result};
 use hypersync_client::{format, format::Hex, net_types, simple_types};
 use num_bigint::{BigInt, BigUint};
-use pyo3::{pyclass, IntoPyObject, PyObject, Python};
+use pyo3::{pyclass, IntoPyObject, Py, PyAny, Python};
 use serde::{Deserialize, Serialize};
 
 /// Data relating to a single event (log)
@@ -208,12 +208,12 @@ pub struct DecodedEvent {
 #[pyclass]
 #[pyo3(get_all)]
 pub struct DecodedSolValue {
-    pub val: PyObject,
+    pub val: Py<PyAny>,
 }
 
 impl Clone for DecodedSolValue {
     fn clone(&self) -> Self {
-        Python::with_gil(|py| Self {
+        Python::attach(|py| Self {
             val: self.val.clone_ref(py),
         })
     }