save

ryoqun · Nov 25, 2023 · 4cce0e6 · 4cce0e6
1 parent 05ff900
commit 4cce0e6
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/scheduler-pool/src/lib.rs b/scheduler-pool/src/lib.rs
@@ -964,10 +964,12 @@ where
                             },
                             recv(if state_machine.has_retryable_task() { ready() } else { never() }) -> now => {
                                 assert!(now.is_ok());
-                                log_scheduler!();
-                                blocked_transaction_sessioned_sender
-                                    .send(ChainedChannel::Payload(state_machine.schedule_retryable_task().unwrap()))
-                                    .unwrap();
+                                if let Some(task) = state_machine.schedule_retryable_task() {
+                                    log_scheduler!();
+                                    blocked_transaction_sessioned_sender
+                                        .send(ChainedChannel::Payload(task))
+                                        .unwrap();
+                                }
                             },
                             recv(handled_idle_transaction_receiver) -> task => {
                                 log_scheduler!();