Skip to content

Commit

Permalink
fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
yezizp2012 committed Jan 8, 2024
1 parent 5718950 commit 8daca2f
Showing 1 changed file with 7 additions and 2 deletions.
9 changes: 7 additions & 2 deletions src/tests/simulation/tests/integration_tests/scale/table.rs
Original file line number Diff line number Diff line change
Expand Up @@ -106,10 +106,15 @@ async fn test_scale_on_schema_change() -> Result<()> {
cluster.run("alter table t add column v2 int").await?;

let fragment = cluster
.locate_one_fragment([identity_contains("materialize"), identity_contains("StreamTableScan")])
.locate_one_fragment([
identity_contains("materialize"),
identity_contains("StreamTableScan"),
])
.await?;

cluster.reschedule_resolve_no_shuffle(fragment.reschedule([1], [0, 4])).await?;
cluster
.reschedule_resolve_no_shuffle(fragment.reschedule([1], [0, 4]))
.await?;

let fragment = cluster
.locate_one_fragment([identity_contains("materialize"), identity_contains("union")])
Expand Down

0 comments on commit 8daca2f

Please sign in to comment.