Skip to content

Commit

Permalink
switched the verification order of input and output queues to priorit…
Browse files Browse the repository at this point in the history
…ize output batch readiness
  • Loading branch information
sergeytimoshin committed Jan 7, 2025
1 parent 8a65eba commit 36908eb
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions forester/src/batch_processor/common.rs
Original file line number Diff line number Diff line change
Expand Up @@ -104,10 +104,10 @@ impl<R: RpcConnection, I: Indexer<R>> BatchProcessor<R, I> {
};
}

if self.verify_input_queue_batch_ready(&mut rpc).await {
BatchReadyState::ReadyForNullify
} else if self.verify_output_queue_batch_ready(&mut rpc).await {
if self.verify_output_queue_batch_ready(&mut rpc).await {
BatchReadyState::ReadyForAppend
} else if self.verify_input_queue_batch_ready(&mut rpc).await {
BatchReadyState::ReadyForNullify
} else {
BatchReadyState::NotReady
}
Expand Down

0 comments on commit 36908eb

Please sign in to comment.