Skip to content
Merged
Changes from 5 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 6 additions & 1 deletion crates/sui-indexer-alt-framework/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -483,6 +483,11 @@ mod tests {
#[async_trait]
impl Processor for ControllableHandler {
const NAME: &'static str = "controllable";
/// The checkpoints to process come out of order. To account for potential flakiness in test
/// `test_tasked_pipelines_skip_checkpoints_trailing_main_reader_lo`, we set the FANOUT to
/// the total number of checkpoints to process, so we can ensure the correct checkpoints are
/// processed.
const FANOUT: usize = 501;
type Value = MockValue;

async fn process(
Expand Down Expand Up @@ -1960,7 +1965,7 @@ mod tests {

/// During a run, the tasked pipeline will stop sending checkpoints below the main pipeline's
/// reader watermark to the committer. Committer watermark should still advance.
#[tokio::test]
#[tokio::test(start_paused = true)]
async fn test_tasked_pipelines_skip_checkpoints_trailing_main_reader_lo() {
let cancel = CancellationToken::new();
let registry = Registry::new();
Expand Down
Loading