fix unit tests

weibocom · Jan 13, 2025 · cb2f9fe · cb2f9fe
1 parent b5c8ebf
commit cb2f9fe
Show file tree

Hide file tree

Showing 19 changed files with 41 additions and 24 deletions.
diff --git a/...ersal/src/main/java/com/weibo/rill/flow/olympicene/traversal/config/OlympiceneFacade.java b/...ersal/src/main/java/com/weibo/rill/flow/olympicene/traversal/config/OlympiceneFacade.java
@@ -47,10 +47,10 @@ public class OlympiceneFacade {
     public static Olympicene build(DAGInfoStorage dagInfoStorage, DAGContextStorage dagContextStorage,
                                    Callback<DAGCallbackInfo> callback, DAGDispatcher dagDispatcher,
                                    DAGStorageProcedure dagStorageProcedure, TimeChecker timeChecker,
-                                   SwitcherManager switcherManager) {
+                                   SwitcherManager switcherManager, Tracer tracer) {
         ExecutorService executor = SameThreadExecutorService.INSTANCE;
         return build(dagInfoStorage, dagContextStorage, dagStorageProcedure, callback, null,
-                dagDispatcher, timeChecker, executor, switcherManager, null);
+                dagDispatcher, timeChecker, executor, switcherManager, tracer);
     }
 
     public static Olympicene build(DAGInfoStorage dagInfoStorage, DAGContextStorage dagContextStorage, DAGStorageProcedure dagStorageProcedure,

diff --git a/...groovy/com/weibo/rill/flow/olympicene/traversal/ChoiceWithForeachTaskTraversalTest.groovy b/...groovy/com/weibo/rill/flow/olympicene/traversal/ChoiceWithForeachTaskTraversalTest.groovy
@@ -20,6 +20,7 @@ import com.weibo.rill.flow.olympicene.traversal.config.OlympiceneFacade
 import com.weibo.rill.flow.olympicene.traversal.dispatcher.DAGDispatcher
 import com.weibo.rill.flow.olympicene.traversal.callback.DAGCallbackInfo
 import com.weibo.rill.flow.olympicene.traversal.callback.DAGEvent
+import io.opentelemetry.api.trace.Tracer
 import spock.lang.Specification
 
 class ChoiceWithForeachTaskTraversalTest extends Specification {
@@ -29,7 +30,7 @@ class ChoiceWithForeachTaskTraversalTest extends Specification {
     DAGDispatcher dispatcher = Mock(DAGDispatcher.class)
     DAGStorageProcedure dagStorageProcedure = new LocalStorageProcedure()
     SwitcherManager switcherManager = Mock(SwitcherManager.class)
-    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager)
+    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager, Mock(Tracer))
 
     /**
      * A -> B -> C

diff --git a/...aversal/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/ConstMappingsTest.groovy b/...aversal/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/ConstMappingsTest.groovy
@@ -22,6 +22,7 @@ import com.weibo.rill.flow.olympicene.traversal.callback.DAGEvent
 import com.weibo.rill.flow.olympicene.traversal.checker.DefaultTimeChecker
 import com.weibo.rill.flow.olympicene.traversal.config.OlympiceneFacade
 import com.weibo.rill.flow.olympicene.traversal.dispatcher.DAGDispatcher
+import io.opentelemetry.api.trace.Tracer
 import spock.lang.Specification
 
 class ConstMappingsTest extends Specification {
@@ -32,7 +33,7 @@ class ConstMappingsTest extends Specification {
     DAGDispatcher dispatcher = Mock(DAGDispatcher.class)
     DAGStorageProcedure dagStorageProcedure = new LocalStorageProcedure()
     SwitcherManager switcherManager = Mock(SwitcherManager.class)
-    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager)
+    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager, Mock(Tracer))
 
     def "test const mappings should work well"() {
         given:

diff --git a/.../src/test/groovy/com/weibo/rill/flow/olympicene/traversal/ForeachTaskTraversalTest.groovy b/.../src/test/groovy/com/weibo/rill/flow/olympicene/traversal/ForeachTaskTraversalTest.groovy
@@ -24,6 +24,7 @@ import com.weibo.rill.flow.olympicene.traversal.dispatcher.DAGDispatcher
 import com.weibo.rill.flow.olympicene.traversal.serialize.DAGTraversalSerializer
 import com.weibo.rill.flow.olympicene.traversal.callback.DAGCallbackInfo
 import com.weibo.rill.flow.olympicene.traversal.callback.DAGEvent
+import io.opentelemetry.api.trace.Tracer
 import spock.lang.Specification
 
 class ForeachTaskTraversalTest extends Specification {
@@ -33,7 +34,7 @@ class ForeachTaskTraversalTest extends Specification {
     DAGDispatcher dispatcher = Mock(DAGDispatcher.class)
     DAGStorageProcedure dagStorageProcedure = new LocalStorageProcedure()
     SwitcherManager switcherManager = Mock(SwitcherManager.class)
-    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager)
+    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager, Mock(Tracer))
 
     /**
      * A -> B -> C

diff --git a/...aversal/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/FunctionRetryTest.groovy b/...aversal/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/FunctionRetryTest.groovy
@@ -20,6 +20,7 @@ import com.weibo.rill.flow.olympicene.traversal.dispatcher.DAGDispatcher
 import com.weibo.rill.flow.olympicene.traversal.callback.DAGCallbackInfo
 import com.weibo.rill.flow.olympicene.traversal.callback.DAGEvent
 import com.weibo.rill.flow.olympicene.traversal.checker.DefaultTimeChecker
+import io.opentelemetry.api.trace.Tracer
 import spock.lang.Specification
 
 class FunctionRetryTest extends Specification {
@@ -30,7 +31,7 @@ class FunctionRetryTest extends Specification {
     DAGStorageProcedure dagStorageProcedure = new LocalStorageProcedure()
     DefaultTimeChecker timeChecker = Mock(DefaultTimeChecker.class)
     SwitcherManager switcherManager = Mock(SwitcherManager.class)
-    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, timeChecker, switcherManager)
+    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, timeChecker, switcherManager, Mock(Tracer))
     DAG dag
 
     def setup() {

diff --git a/...groovy/com/weibo/rill/flow/olympicene/traversal/FunctionTaskToleranceTraversalTest.groovy b/...groovy/com/weibo/rill/flow/olympicene/traversal/FunctionTaskToleranceTraversalTest.groovy
@@ -21,6 +21,7 @@ import com.weibo.rill.flow.olympicene.traversal.dispatcher.DAGDispatcher
 import com.weibo.rill.flow.olympicene.traversal.callback.DAGCallbackInfo
 import com.weibo.rill.flow.olympicene.traversal.callback.DAGEvent
 import com.weibo.rill.flow.olympicene.traversal.checker.DefaultTimeChecker
+import io.opentelemetry.api.trace.Tracer
 import spock.lang.Specification
 
 class FunctionTaskToleranceTraversalTest extends Specification {
@@ -30,7 +31,7 @@ class FunctionTaskToleranceTraversalTest extends Specification {
     DAGDispatcher dispatcher = Mock(DAGDispatcher.class)
     DAGStorageProcedure dagStorageProcedure = new LocalStorageProcedure()
     SwitcherManager switcherManager = Mock(SwitcherManager.class)
-    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager)
+    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager, Mock(Tracer))
 
     def "test one functionTask skip dag should work well"() {
         given:

diff --git a/...st/groovy/com/weibo/rill/flow/olympicene/traversal/FunctionTaskTraversalFailedTest.groovy b/...st/groovy/com/weibo/rill/flow/olympicene/traversal/FunctionTaskTraversalFailedTest.groovy
@@ -21,6 +21,7 @@ import com.weibo.rill.flow.olympicene.traversal.callback.DAGEvent
 import com.weibo.rill.flow.olympicene.traversal.checker.DefaultTimeChecker
 import com.weibo.rill.flow.olympicene.traversal.config.OlympiceneFacade
 import com.weibo.rill.flow.olympicene.traversal.dispatcher.DAGDispatcher
+import io.opentelemetry.api.trace.Tracer
 import spock.lang.Specification
 
 class FunctionTaskTraversalFailedTest extends Specification {
@@ -31,7 +32,7 @@ class FunctionTaskTraversalFailedTest extends Specification {
     DAGDispatcher dispatcher = Mock(DAGDispatcher.class)
     DAGStorageProcedure dagStorageProcedure = new LocalStorageProcedure()
     SwitcherManager switcherManager = Mock(SwitcherManager.class)
-    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager)
+    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager, Mock(Tracer))
 
     def "test one functionTask failed dag should work well"() {
         given:

diff --git a/...src/test/groovy/com/weibo/rill/flow/olympicene/traversal/FunctionTaskTraversalTest.groovy b/...src/test/groovy/com/weibo/rill/flow/olympicene/traversal/FunctionTaskTraversalTest.groovy
@@ -21,6 +21,7 @@ import com.weibo.rill.flow.olympicene.traversal.callback.DAGEvent
 import com.weibo.rill.flow.olympicene.traversal.checker.DefaultTimeChecker
 import com.weibo.rill.flow.olympicene.traversal.config.OlympiceneFacade
 import com.weibo.rill.flow.olympicene.traversal.dispatcher.DAGDispatcher
+import io.opentelemetry.api.trace.Tracer
 import spock.lang.Specification
 
 class FunctionTaskTraversalTest extends Specification {
@@ -31,7 +32,7 @@ class FunctionTaskTraversalTest extends Specification {
     DAGDispatcher dispatcher = Mock(DAGDispatcher.class)
     DAGStorageProcedure dagStorageProcedure = new LocalStorageProcedure()
     SwitcherManager switcherManager = Mock(SwitcherManager.class)
-    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager)
+    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager, Mock(Tracer))
 
     def "test one functionTask dag should work well"() {
         given:

diff --git a/...e-traversal/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/InvokeMsgTest.groovy b/...e-traversal/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/InvokeMsgTest.groovy
@@ -21,6 +21,7 @@ import com.weibo.rill.flow.olympicene.traversal.callback.DAGEvent
 import com.weibo.rill.flow.olympicene.traversal.checker.DefaultTimeChecker
 import com.weibo.rill.flow.olympicene.traversal.config.OlympiceneFacade
 import com.weibo.rill.flow.olympicene.traversal.dispatcher.DAGDispatcher
+import io.opentelemetry.api.trace.Tracer
 import spock.lang.Specification
 
 class InvokeMsgTest extends Specification {
@@ -30,7 +31,7 @@ class InvokeMsgTest extends Specification {
     DAGDispatcher dispatcher = Mock(DAGDispatcher.class)
     DAGStorageProcedure dagStorageProcedure = new LocalStorageProcedure()
     SwitcherManager switcherManager = Mock(SwitcherManager.class)
-    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager)
+    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager, Mock(Tracer))
 
     def setup() {
         switcherManager.getSwitcherState("ENABLE_SET_INPUT_OUTPUT") >> true

diff --git a/...-traversal/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/InvokeTimeTest.groovy b/...-traversal/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/InvokeTimeTest.groovy
@@ -21,6 +21,7 @@ import com.weibo.rill.flow.olympicene.traversal.config.OlympiceneFacade
 import com.weibo.rill.flow.olympicene.traversal.dispatcher.DAGDispatcher
 import com.weibo.rill.flow.olympicene.traversal.callback.DAGCallbackInfo
 import com.weibo.rill.flow.olympicene.traversal.callback.DAGEvent
+import io.opentelemetry.api.trace.Tracer
 import org.apache.commons.collections.CollectionUtils
 import spock.lang.Specification
 
@@ -31,7 +32,7 @@ class InvokeTimeTest extends Specification {
     DAGDispatcher dispatcher = Mock(DAGDispatcher.class)
     DAGStorageProcedure dagStorageProcedure = new LocalStorageProcedure()
     SwitcherManager switcherManager = Mock(SwitcherManager.class)
-    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager)
+    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager, Mock(Tracer))
     String executionId = 'executionId'
 
     def "dagInfo and taskInfo should save invoke time"() {

diff --git a/...ne-traversal/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/MultiDAGTest.groovy b/...ne-traversal/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/MultiDAGTest.groovy
@@ -21,6 +21,7 @@ import com.weibo.rill.flow.olympicene.traversal.dispatcher.DAGDispatcher
 import com.weibo.rill.flow.olympicene.traversal.exception.DAGTraversalException
 import com.weibo.rill.flow.olympicene.traversal.checker.DefaultTimeChecker
 import groovy.util.logging.Slf4j
+import io.opentelemetry.api.trace.Tracer
 import spock.lang.Specification
 
 @Slf4j
@@ -31,7 +32,7 @@ class MultiDAGTest extends Specification {
     DAGDispatcher dispatcher = Mock(DAGDispatcher.class)
     DAGStorageProcedure dagStorageProcedure = new LocalStorageProcedure()
     SwitcherManager switcherManager = Mock(SwitcherManager.class)
-    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager)
+    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager, Mock(Tracer))
     DAG dag
 
     def setup() {

diff --git a/...sal/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/PassTaskTraversalTest.groovy b/...sal/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/PassTaskTraversalTest.groovy
@@ -1,27 +1,27 @@
 package com.weibo.rill.flow.olympicene.traversal
 
+import com.weibo.rill.flow.interfaces.model.task.TaskStatus
 import com.weibo.rill.flow.olympicene.core.event.Callback
 import com.weibo.rill.flow.olympicene.core.event.Event
 import com.weibo.rill.flow.olympicene.core.model.DAGSettings
 import com.weibo.rill.flow.olympicene.core.model.NotifyInfo
 import com.weibo.rill.flow.olympicene.core.model.dag.DAG
 import com.weibo.rill.flow.olympicene.core.model.dag.DAGStatus
-import com.weibo.rill.flow.interfaces.model.task.TaskStatus
 import com.weibo.rill.flow.olympicene.core.runtime.DAGParser
 import com.weibo.rill.flow.olympicene.core.runtime.DAGStorageProcedure
 import com.weibo.rill.flow.olympicene.core.switcher.SwitcherManager
 import com.weibo.rill.flow.olympicene.ddl.parser.DAGStringParser
 import com.weibo.rill.flow.olympicene.ddl.serialize.YAMLSerializer
 import com.weibo.rill.flow.olympicene.ddl.validation.dag.impl.FlowDAGValidator
 import com.weibo.rill.flow.olympicene.ddl.validation.task.impl.FunctionTaskValidator
-import com.weibo.rill.flow.olympicene.storage.redis.api.RedisClient
 import com.weibo.rill.flow.olympicene.storage.save.impl.DAGLocalStorage
 import com.weibo.rill.flow.olympicene.storage.save.impl.LocalStorageProcedure
+import com.weibo.rill.flow.olympicene.traversal.callback.DAGCallbackInfo
+import com.weibo.rill.flow.olympicene.traversal.callback.DAGEvent
 import com.weibo.rill.flow.olympicene.traversal.checker.DefaultTimeChecker
 import com.weibo.rill.flow.olympicene.traversal.config.OlympiceneFacade
 import com.weibo.rill.flow.olympicene.traversal.dispatcher.DAGDispatcher
-import com.weibo.rill.flow.olympicene.traversal.callback.DAGCallbackInfo
-import com.weibo.rill.flow.olympicene.traversal.callback.DAGEvent
+import io.opentelemetry.api.trace.Tracer
 import spock.lang.Specification
 
 class PassTaskTraversalTest extends Specification {
@@ -31,7 +31,7 @@ class PassTaskTraversalTest extends Specification {
     DAGDispatcher dispatcher = Mock(DAGDispatcher.class)
     DAGStorageProcedure dagStorageProcedure = new LocalStorageProcedure()
     SwitcherManager switcherManager = Mock(SwitcherManager.class)
-    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager)
+    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager, Mock(Tracer))
 
     def "test one passTask dag should work well"() {
         given:

diff --git a/...aversal/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/RedoTraversalTest.groovy b/...aversal/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/RedoTraversalTest.groovy
@@ -20,6 +20,7 @@ import com.weibo.rill.flow.olympicene.traversal.checker.DefaultTimeChecker
 import com.weibo.rill.flow.olympicene.traversal.config.OlympiceneFacade
 import com.weibo.rill.flow.olympicene.traversal.dispatcher.DAGDispatcher
 import groovy.util.logging.Slf4j
+import io.opentelemetry.api.trace.Tracer
 import spock.lang.Specification
 
 
@@ -31,7 +32,7 @@ class RedoTraversalTest extends Specification {
     DAGDispatcher dispatcher = Mock(DAGDispatcher.class)
     DAGStorageProcedure dagStorageProcedure = new LocalStorageProcedure()
     SwitcherManager switcherManager = Mock(SwitcherManager.class)
-    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager)
+    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager, Mock(Tracer))
     String executionId = "xxx1"
     DAG dag
 

diff --git a/...l/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/ReturnTaskTraversalTest.groovy b/...l/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/ReturnTaskTraversalTest.groovy
@@ -18,6 +18,7 @@ import com.weibo.rill.flow.olympicene.traversal.dispatcher.DAGDispatcher
 import com.weibo.rill.flow.olympicene.traversal.callback.DAGCallbackInfo
 import com.weibo.rill.flow.olympicene.traversal.callback.DAGEvent
 import com.weibo.rill.flow.olympicene.traversal.checker.DefaultTimeChecker
+import io.opentelemetry.api.trace.Tracer
 import spock.lang.Specification
 
 
@@ -28,7 +29,7 @@ class ReturnTaskTraversalTest extends Specification {
     DAGDispatcher dispatcher = Mock(DAGDispatcher.class)
     DAGStorageProcedure dagStorageProcedure = new LocalStorageProcedure()
     SwitcherManager switcherManager = Mock(SwitcherManager.class)
-    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager)
+    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager, Mock(Tracer))
 
     def "if return task status is success then next tasks status should be skip"() {
         given:

diff --git a/...src/test/groovy/com/weibo/rill/flow/olympicene/traversal/SuspenseTaskTraversalTest.groovy b/...src/test/groovy/com/weibo/rill/flow/olympicene/traversal/SuspenseTaskTraversalTest.groovy
@@ -23,6 +23,7 @@ import com.weibo.rill.flow.olympicene.traversal.dispatcher.DAGDispatcher
 import com.weibo.rill.flow.olympicene.traversal.callback.DAGCallbackInfo
 import com.weibo.rill.flow.olympicene.traversal.callback.DAGEvent
 import com.weibo.rill.flow.olympicene.traversal.checker.DefaultTimeChecker
+import io.opentelemetry.api.trace.Tracer
 import spock.lang.Specification
 
 class SuspenseTaskTraversalTest extends Specification {
@@ -32,7 +33,7 @@ class SuspenseTaskTraversalTest extends Specification {
     DAGDispatcher dispatcher = Mock(DAGDispatcher.class)
     DAGStorageProcedure dagStorageProcedure = new LocalStorageProcedure()
     SwitcherManager switcherManager = Mock(SwitcherManager.class)
-    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager)
+    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager, Mock(Tracer))
 
     def "test suspense task"() {
         given:

diff --git a/...l/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/SwitchTaskTraversalTest.groovy b/...l/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/SwitchTaskTraversalTest.groovy
@@ -18,6 +18,7 @@ import com.weibo.rill.flow.olympicene.traversal.callback.DAGEvent
 import com.weibo.rill.flow.olympicene.traversal.checker.DefaultTimeChecker
 import com.weibo.rill.flow.olympicene.traversal.config.OlympiceneFacade
 import com.weibo.rill.flow.olympicene.traversal.dispatcher.DAGDispatcher
+import io.opentelemetry.api.trace.Tracer
 import spock.lang.Specification
 
 class SwitchTaskTraversalTest extends Specification {
@@ -27,7 +28,7 @@ class SwitchTaskTraversalTest extends Specification {
     DAGDispatcher dispatcher = Mock(DAGDispatcher.class)
     DAGStorageProcedure dagStorageProcedure = new LocalStorageProcedure()
     SwitcherManager switcherManager = Mock(SwitcherManager.class)
-    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager)
+    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager, Mock(Tracer))
 
     def "test basic switch"() {
         given:

diff --git a/...traversal/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/TaskDegradeTest.groovy b/...traversal/src/test/groovy/com/weibo/rill/flow/olympicene/traversal/TaskDegradeTest.groovy
@@ -19,6 +19,7 @@ import com.weibo.rill.flow.olympicene.traversal.config.OlympiceneFacade
 import com.weibo.rill.flow.olympicene.traversal.dispatcher.DAGDispatcher
 import com.weibo.rill.flow.olympicene.traversal.callback.DAGCallbackInfo
 import com.weibo.rill.flow.olympicene.traversal.callback.DAGEvent
+import io.opentelemetry.api.trace.Tracer
 import spock.lang.Specification
 
 
@@ -29,7 +30,7 @@ class TaskDegradeTest extends Specification {
     DAGDispatcher dispatcher = Mock(DAGDispatcher.class)
     DAGStorageProcedure dagStorageProcedure = new LocalStorageProcedure()
     SwitcherManager switcherManager = Mock(SwitcherManager.class)
-    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager)
+    Olympicene olympicene = OlympiceneFacade.build(dagStorage, dagStorage, callback, dispatcher, dagStorageProcedure, Mock(DefaultTimeChecker.class), switcherManager, Mock(Tracer))
 
     def "degrade current task only test"() {
         given: