fix compile

risingwavelabs · Nov 18, 2024 · 1411059 · 1411059
1 parent b0d719f
commit 1411059
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/src/tests/simulation/tests/integration_tests/sink/basic.rs b/src/tests/simulation/tests/integration_tests/sink/basic.rs
@@ -46,7 +46,7 @@ async fn basic_test_inner(is_decouple: bool) -> Result<()> {
     session.run(CREATE_SINK).await?;
 
     if test_sink.parallelism_counter.load(Relaxed) != 6 {
-        return Err(anyhow!(
+        return Err(anyhow::anyhow!(
             "incorrect initial parallelism: {} ",
             test_sink.parallelism_counter.load(Relaxed)
         ));

diff --git a/src/tests/simulation/tests/integration_tests/sink/err_isolation.rs b/src/tests/simulation/tests/integration_tests/sink/err_isolation.rs
@@ -42,7 +42,7 @@ async fn test_sink_decouple_err_isolation() -> Result<()> {
     session.run(CREATE_SINK).await?;
 
     if test_sink.parallelism_counter.load(Relaxed) != 6 {
-        return Err(anyhow!(
+        return Err(anyhow::anyhow!(
             "incorrect initial parallelism: {} ",
             test_sink.parallelism_counter.load(Relaxed)
         ));
@@ -89,7 +89,7 @@ async fn test_sink_error_event_logs() -> Result<()> {
     session.run(CREATE_SINK).await?;
 
     if test_sink.parallelism_counter.load(Relaxed) != 6 {
-        return Err(anyhow!(
+        return Err(anyhow::anyhow!(
             "incorrect initial parallelism: {} ",
             test_sink.parallelism_counter.load(Relaxed)
         ));

diff --git a/src/tests/simulation/tests/integration_tests/sink/recovery.rs b/src/tests/simulation/tests/integration_tests/sink/recovery.rs
@@ -72,7 +72,7 @@ async fn recovery_test_inner(is_decouple: bool) -> Result<()> {
     session.run(CREATE_SOURCE).await?;
     session.run(CREATE_SINK).await?;
     if test_sink.parallelism_counter.load(Relaxed) != 6 {
-        return Err(anyhow!(
+        return Err(anyhow::anyhow!(
             "incorrect initial parallelism: {} ",
             test_sink.parallelism_counter.load(Relaxed)
         ));

diff --git a/src/tests/simulation/tests/integration_tests/sink/scale.rs b/src/tests/simulation/tests/integration_tests/sink/scale.rs
@@ -75,7 +75,7 @@ async fn scale_test_inner(is_decouple: bool) -> Result<()> {
     session.run(CREATE_SINK).await?;
 
     if test_sink.parallelism_counter.load(Relaxed) != 6 {
-        return Err(anyhow!(
+        return Err(anyhow::anyhow!(
             "incorrect initial parallelism: {} ",
             test_sink.parallelism_counter.load(Relaxed)
         ));