diff --git a/src/runtime2/connector.rs b/src/runtime2/connector.rs index 03499cbc17803f00590555ee5de61b0553487c4d..5495680cd51dc7f94a8de2fa83a3e7a6d0eba35d 100644 --- a/src/runtime2/connector.rs +++ b/src/runtime2/connector.rs @@ -403,12 +403,14 @@ impl ConnectorPDL { ); self.eval_error = Some(eval_error); self.mode = Mode::SyncError; + + println!("DEBUGERINO: Notify of fatal branch"); + if let Some(conclusion) = self.consensus.notify_of_fatal_branch(branch_id, comp_ctx) { + println!("DEBUGERINO: Actually got {:?}", conclusion); + return self.enter_non_sync_mode(conclusion, comp_ctx); + } } } - - branch.prepared = PreparedStatement::PerformedPut; - self.tree.push_into_queue(QueueKind::Runnable, branch_id); - return ConnectorScheduling::Immediate; }, _ => unreachable!("unexpected run result {:?} in sync mode", run_result), }