File tree Expand file tree Collapse file tree 1 file changed +8
-6
lines changed
src/test/java/com/uber/cadence/workflow Expand file tree Collapse file tree 1 file changed +8
-6
lines changed Original file line number Diff line number Diff line change @@ -108,21 +108,21 @@ public void executeChild() {
108
108
}
109
109
}
110
110
111
- @ Before
112
- public void setUp () {
111
+ public void setUp (com .uber .m3 .util .Duration reportingFrequecy ){
113
112
reporter = mock (StatsReporter .class );
114
113
Scope scope =
115
- new RootScopeBuilder ()
116
- .reporter (reporter )
117
- .reportEvery (com . uber . m3 . util . Duration . ofMillis ( 300 ) );
114
+ new RootScopeBuilder ()
115
+ .reporter (reporter )
116
+ .reportEvery (reportingFrequecy );
118
117
119
118
TestEnvironmentOptions testOptions =
120
- new Builder ().setDomain (WorkflowTest .DOMAIN ).setMetricsScope (scope ).build ();
119
+ new Builder ().setDomain (WorkflowTest .DOMAIN ).setMetricsScope (scope ).build ();
121
120
testEnvironment = TestWorkflowEnvironment .newInstance (testOptions );
122
121
}
123
122
124
123
@ Test
125
124
public void testWorkflowMetrics () throws InterruptedException {
125
+ setUp (com .uber .m3 .util .Duration .ofMillis (10 ));
126
126
127
127
Worker worker = testEnvironment .newWorker (taskList );
128
128
worker .registerWorkflowImplementationTypes (
@@ -166,6 +166,8 @@ public void testWorkflowMetrics() throws InterruptedException {
166
166
167
167
@ Test
168
168
public void testCorruptedSignalMetrics () throws InterruptedException {
169
+ setUp (com .uber .m3 .util .Duration .ofMillis (300 ));
170
+
169
171
Worker worker = testEnvironment .newWorker (taskList , builder ->
170
172
builder .setInterceptorFactory (new CorruptedSignalWorkflowInterceptorFactory ()));
171
173
You can’t perform that action at this time.
0 commit comments