Skip to content

Commit d0ebf7b

Browse files
committed
[dbsp] Simplify transaction state tracking in scheduler.
Remove redundant TransactionPhase::Idle status. Signed-off-by: Leonid Ryzhyk <ryzhyk@gmail.com>
1 parent ddaaf08 commit d0ebf7b

1 file changed

Lines changed: 1 addition & 4 deletions

File tree

crates/dbsp/src/circuit/schedule/dynamic_scheduler.rs

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -147,9 +147,6 @@ impl Notifications {
147147
}
148148

149149
enum TransactionPhase {
150-
/// Not started
151-
Idle,
152-
153150
/// Started, but not yet committing.
154151
Started,
155152

@@ -360,7 +357,7 @@ impl Inner {
360357
notifications: Notifications::new(num_async_nodes),
361358
handles: JoinSet::new(),
362359
waiting: false,
363-
transaction_phase: TransactionPhase::Idle,
360+
transaction_phase: TransactionPhase::CommitComplete,
364361
global_commit_consensus: Broadcast::new(),
365362
metadata_broadcast: Broadcast::new(),
366363
before_first_step: true,

0 commit comments

Comments
 (0)