fmt

risingwavelabs · Dec 4, 2024 · 4627f11 · 4627f11
1 parent 9b77d20
commit 4627f11
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/compute/tests/integration_tests.rs b/src/compute/tests/integration_tests.rs
@@ -187,7 +187,7 @@ async fn test_table_materialize() -> StreamResult<()> {
             identity: format!("DmlExecutor {:X}", 2),
         },
         DmlExecutor::new(
-            ActorContext::for_test(0).into(),
+            ActorContext::for_test(0),
             source_executor,
             dml_manager.clone(),
             table_id,

diff --git a/src/stream/src/executor/dml.rs b/src/stream/src/executor/dml.rs
@@ -451,7 +451,7 @@ mod tests {
         let source = source.into_executor(schema, pk_indices);
 
         let dml_executor = DmlExecutor::new(
-            ActorContext::for_test(0).into(),
+            ActorContext::for_test(0),
             source,
             dml_manager.clone(),
             table_id,