Skip to content

Commit

Permalink
fix build for simulation
Browse files Browse the repository at this point in the history
Signed-off-by: Runji Wang <[email protected]>
  • Loading branch information
wangrunji0408 committed Feb 28, 2023
1 parent 59c0058 commit ab40932
Show file tree
Hide file tree
Showing 4 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion Makefile.toml
Original file line number Diff line number Diff line change
Expand Up @@ -667,7 +667,7 @@ script = """
#!/usr/bin/env bash
set -e
cargo check -p risingwave_simulation "$@"
cargo check -p risingwave_simulation --all-targets "$@"
"""

[tasks.sslt]
Expand Down
1 change: 0 additions & 1 deletion src/tests/simulation/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -137,7 +137,6 @@ pub struct Args {
#[cfg(madsim)]
#[madsim::main]
async fn main() {
use std::env;
use std::sync::Arc;

use risingwave_simulation::client::RisingWave;
Expand Down
1 change: 1 addition & 0 deletions src/tests/simulation/tests/it/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@ mod dynamic_filter;
mod hello;
mod nexmark_chaos;
mod nexmark_q4;
mod nexmark_recovery;
mod nexmark_source;
mod singleton_migration;
mod streaming_parallelism;
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ async fn nexmark_recovery_common(create: &str, select: &str, drop: &str) -> Resu
// .init();

let mut cluster =
NexmarkCluster::new(Configuration::for_scale(), 6, Some(THROUGHPUT * 20)).await?;
NexmarkCluster::new(Configuration::for_scale(), 6, Some(THROUGHPUT * 20), false).await?;

// get the output without failures as the standard result
cluster.run(create).await?;
Expand Down

0 comments on commit ab40932

Please sign in to comment.