geyser: wrap geyser_loop with unconstrained (#313)

rpcpool · Apr 4, 2024 · a2bb340 · a2bb340
1 parent 641bf98
commit a2bb340
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -19,6 +19,7 @@ The minor version will be incremented upon a breaking change and the patch versi
 - client: add gRPC channel options to Node.js ([#306](https://github.com/rpcpool/yellowstone-grpc/pull/306))
 - geyser: add `transactions_status` filter ([#310](https://github.com/rpcpool/yellowstone-grpc/pull/310))
 - geyser: add metric `slot_status_plugin` ([#312](https://github.com/rpcpool/yellowstone-grpc/pull/312))
+- geyser: wrap `geyser_loop` with `unconstrained` ([#313](https://github.com/rpcpool/yellowstone-grpc/pull/313))
 
 ### Breaking
 

diff --git a/yellowstone-grpc-geyser/src/grpc.rs b/yellowstone-grpc-geyser/src/grpc.rs
@@ -784,12 +784,12 @@ impl GrpcService {
 
         // Run geyser message loop
         let (messages_tx, messages_rx) = mpsc::unbounded_channel();
-        tokio::spawn(Self::geyser_loop(
+        tokio::spawn(tokio::task::unconstrained(Self::geyser_loop(
             messages_rx,
             blocks_meta_tx,
             broadcast_tx,
             block_fail_action,
-        ));
+        )));
 
         // Run Server
         let shutdown = Arc::new(Notify::new());