unblock executor thread

iosis-tech · Jul 6, 2024 · 24daf82 · 24daf82
1 parent eef1eb1
commit 24daf82
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/crates/executor/src/executor.rs b/crates/executor/src/executor.rs
@@ -92,7 +92,7 @@ impl Executor {
                         && !job_record.is_empty()
                     {
                         if let Some(job) = job_record.take_job().await {
-                            if let Some(event) = events_rx.recv().await {
+                            if let Ok(event) = events_rx.try_recv() {
                                 match event {
                                     Event::Message { message, .. } => {
                                         // Received a new-job message from the network