(shardingsphere) branch master updated: Refactor PipelineProcessConfigurationPersistServiceTest (#37983)

[zhangliang]

This is an automated email from the ASF dual-hosted git repository.

zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new a24f5c16138 Refactor PipelineProcessConfigurationPersistServiceTest 
(#37983)
a24f5c16138 is described below

commit a24f5c16138ee6cf5b1858e569cf921d1825d525
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Sun Feb 8 23:16:06 2026 +0800

    Refactor PipelineProcessConfigurationPersistServiceTest (#37983)
---
 .../metadata/PipelineProcessConfigurationPersistServiceTest.java  | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/data/pipeline/core/metadata/PipelineProcessConfigurationPersistServiceTest.java
 
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/data/pipeline/core/metadata/PipelineProcessConfigurationPersistServiceTest.java
index 0344a7aab45..a1abeddb96d 100644
--- 
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/data/pipeline/core/metadata/PipelineProcessConfigurationPersistServiceTest.java
+++ 
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/data/pipeline/core/metadata/PipelineProcessConfigurationPersistServiceTest.java
@@ -31,6 +31,7 @@ import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.ValueSource;
 
 import java.util.Map;
+import java.util.Map.Entry;
 import java.util.Properties;
 import java.util.function.BiConsumer;
 
@@ -85,10 +86,9 @@ class PipelineProcessConfigurationPersistServiceTest {
     @ParameterizedTest
     @ValueSource(strings = {"MIGRATION", "STREAMING"})
     void assertPersistAndLoad(final String jobType) {
-        for (String each : typesAssertionMap.keySet()) {
-            YamlPipelineProcessConfiguration expected = 
createYamlPipelineProcessConfiguration(each);
-            YamlPipelineProcessConfiguration actual = persistAndLoad(jobType, 
expected);
-            typesAssertionMap.get(each).accept(actual, expected);
+        for (Entry<String, BiConsumer<YamlPipelineProcessConfiguration, 
YamlPipelineProcessConfiguration>> entry : typesAssertionMap.entrySet()) {
+            YamlPipelineProcessConfiguration expected = 
createYamlPipelineProcessConfiguration(entry.getKey());
+            entry.getValue().accept(persistAndLoad(jobType, expected), 
expected);
         }
     }