We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ddaaf08 commit d0ebf7bCopy full SHA for d0ebf7b
1 file changed
crates/dbsp/src/circuit/schedule/dynamic_scheduler.rs
@@ -147,9 +147,6 @@ impl Notifications {
147
}
148
149
enum TransactionPhase {
150
- /// Not started
151
- Idle,
152
-
153
/// Started, but not yet committing.
154
Started,
155
@@ -360,7 +357,7 @@ impl Inner {
360
357
notifications: Notifications::new(num_async_nodes),
361
358
handles: JoinSet::new(),
362
359
waiting: false,
363
- transaction_phase: TransactionPhase::Idle,
+ transaction_phase: TransactionPhase::CommitComplete,
364
global_commit_consensus: Broadcast::new(),
365
metadata_broadcast: Broadcast::new(),
366
before_first_step: true,
0 commit comments