fix the recursive read deadlock

Author: ljeub-pometry

raphtory-core/src/storage/raw_edges.rs

@@ -187,7 +187,7 @@ impl EdgesStorage {
     pub fn get_edge(&self, eid: EID) -> EdgeRGuard {
         let (bucket, offset) = self.resolve(eid.into());
         EdgeRGuard {
-            guard: self.shards[bucket].read(),
+            guard: self.shards[bucket].read_recursive(),
             offset,
         }
     }

raphtory-graphql/src/rayon.rs

@@ -2,12 +2,6 @@ use rayon::{ThreadPool, ThreadPoolBuilder};
 use std::sync::LazyLock;
 use tokio::sync::oneshot;
 
-static WRITE_POOL: LazyLock<ThreadPool> = LazyLock::new(|| {
-    ThreadPoolBuilder::new()
-        .build()
-        .expect("failed to build threadpool")
-});
-
 /// Use the rayon threadpool to execute a task
 ///
 /// Use this for long-running, compute-heavy work
@@ -25,7 +19,7 @@ pub async fn blocking_compute<R: Send + 'static, F: FnOnce() -> R + Send + 'stat
 /// Use a separate rayon threadpool to execute write tasks to avoid potential deadlocks
 pub async fn blocking_write<R: Send + 'static, F: FnOnce() -> R + Send + 'static>(closure: F) -> R {
     let (send, recv) = oneshot::channel();
-    WRITE_POOL.spawn(move || {
+    rayon::spawn(move || {
         let _ = send.send(closure()); // this only errors if no-one is listening anymore
     });
     recv.await.expect("Function panicked in rayon::spawn")