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

terrymanu 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 a326cb1db10 Remove unrelated pipeline API factory test (#39774)
a326cb1db10 is described below

commit a326cb1db10124f6df09b8a20fa10a534bb8f3ed
Author: Liang Zhang <[email protected]>
AuthorDate: Wed Sep 9 01:12:02 2026 +0800

    Remove unrelated pipeline API factory test (#39774)
---
 .../pipeline/core/job/api/PipelineAPIFactoryTest.java     | 15 ---------------
 1 file changed, 15 deletions(-)

diff --git 
a/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/job/api/PipelineAPIFactoryTest.java
 
b/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/job/api/PipelineAPIFactoryTest.java
index bdcda1c865c..7036e91facc 100644
--- 
a/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/job/api/PipelineAPIFactoryTest.java
+++ 
b/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/job/api/PipelineAPIFactoryTest.java
@@ -18,7 +18,6 @@
 package org.apache.shardingsphere.data.pipeline.core.job.api;
 
 import lombok.SneakyThrows;
-import org.apache.commons.lang3.concurrent.ConcurrentException;
 import org.apache.shardingsphere.data.pipeline.core.context.PipelineContextKey;
 import 
org.apache.shardingsphere.data.pipeline.core.context.PipelineContextManager;
 import 
org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode;
@@ -128,20 +127,6 @@ class PipelineAPIFactoryTest {
         }
     }
     
-    @Test
-    void assertGetPipelineGovernanceFacadePropagatesInitializationFailure() {
-        PipelineContextKey contextKey = new PipelineContextKey("error_db", 
InstanceType.JDBC);
-        ConcurrentException expected = new ConcurrentException(new 
Exception("expected"));
-        try (MockedStatic<PipelineContextManager> contextManager = 
mockStatic(PipelineContextManager.class)) {
-            contextManager.when(() -> 
PipelineContextManager.getContext(contextKey)).thenAnswer(invocation -> {
-                throw expected;
-            });
-            assertThat(assertThrows(ConcurrentException.class, () -> 
PipelineAPIFactory.getPipelineGovernanceFacade(contextKey)), 
sameInstance(expected));
-        } finally {
-            PipelineAPIFactory.close(contextKey);
-        }
-    }
-    
     private ClusterPersistRepositoryConfiguration mockContext(final 
PipelineContextKey contextKey, final MockedStatic<PipelineContextManager> 
pipelineContextManager) {
         ClusterPersistRepositoryConfiguration result = new 
ClusterPersistRepositoryConfiguration("FIXTURE", "namespace", "serverLists", 
new Properties());
         ContextManager contextManager = mock(ContextManager.class, 
RETURNS_DEEP_STUBS);

Reply via email to