IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

consolidate error tests

Browse Source
This commit is contained in:
Jonathan Shook 2023-01-05 14:36:58 -06:00
parent fb8e27d339
commit f412505690
3 changed files with 25 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
nbr-examples/src/test/java/io/nosqlbench/nbr/examples/ScriptExampleTests.java
View File

@ -234,15 +234,6 @@ public class ScriptExampleTests {
"shutdown hooks should not run in the same IO context as the main scenario" "shutdown hooks should not run in the same IO context as the main scenario"
); );
} }
@Test
public void testExceptionPropagationFromActivityInit() {
ExecutionMetricsResult scenarioResult = runScenario("activityiniterror");
assertThat(scenarioResult.getException()).isNotNull();
assertThat(scenarioResult.getException().getMessage()).contains("Unable to convert end cycle from invalid");
assertThat(scenarioResult.getException()).isNotNull();
}
@Test @Test
public void testReportedCoDelayBursty() { public void testReportedCoDelayBursty() {
ExecutionMetricsResult scenarioResult = runScenario("cocycledelay_bursty"); ExecutionMetricsResult scenarioResult = runScenario("cocycledelay_bursty");
@ -272,11 +263,28 @@ public class ScriptExampleTests {
} }
@Test @Test
public void testExitLogic() { public void testErrorPropagationFromAdapterOperation() {
ExecutionMetricsResult scenarioResult = runScenario( ExecutionMetricsResult scenarioResult = runScenario(
"basicdiag", "basicdiag",
"type", "diag", "cyclerate", "5", "erroroncycle", "10", "cycles", "2000" "type", "diag", "cyclerate", "5", "erroroncycle", "10", "cycles", "2000"
); );
} }
@Test
public void testErrorPropagationFromMotorThread() {
ExecutionMetricsResult scenarioResult = runScenario("activity_error");
assertThat(scenarioResult.getException()).isNotNull();
assertThat(scenarioResult.getException().getMessage()).contains("For input string: \"unparsable\"");
}
@Test
public void testErrorPropagationFromActivityInitialization() {
ExecutionMetricsResult scenarioResult = runScenario("activity_init_error");
assertThat(scenarioResult.getException()).isNotNull();
assertThat(scenarioResult.getException().getMessage()).contains("Unable to convert end cycle from invalid");
assertThat(scenarioResult.getException()).isNotNull();
}
} }

8
nbr-examples/src/test/resources/scripts/examples/activityerror.js → nbr-examples/src/test/resources/scripts/examples/activity_error.js
View File

@ -15,7 +15,7 @@
*/ */
activitydef1 = { activitydef1 = {
"alias" : "erroring_activity", "alias" : "activity_error",
"driver" : "diag", "driver" : "diag",
"cycles" : "0..1500000", "cycles" : "0..1500000",
"threads" : "1", "threads" : "1",
@ -25,9 +25,9 @@ activitydef1 = {
} }
}; };
print('starting activity erroring_activity'); print('starting activity activity_error');
scenario.start(activitydef1); scenario.start(activitydef1);
scenario.waitMillis(2000); scenario.waitMillis(2000);
activities.erroring_activity.threads="unparsable"; activities.activity_error.threads="unparsable";
scenario.awaitActivity("erroring_activity"); scenario.awaitActivity("activity_error");
print("awaited activity"); print("awaited activity");

6
nbr-examples/src/test/resources/scripts/examples/activityiniterror.js → nbr-examples/src/test/resources/scripts/examples/activity_init_error.js
View File

@ -15,7 +15,7 @@
*/ */
activitydef1 = { activitydef1 = {
"alias" : "erroring_activity_init", "alias" : "activity_init_error",
"driver" : "diag", "driver" : "diag",
"cycles" : "invalid", "cycles" : "invalid",
"threads" : "1", "threads" : "1",
@ -24,8 +24,8 @@ activitydef1 = {
"op" : "noop" "op" : "noop"
}; };
print('starting activity erroring_activity_init'); print('starting activity activity_init_error');
scenario.start(activitydef1); scenario.start(activitydef1);
scenario.waitMillis(2000); scenario.waitMillis(2000);
scenario.awaitActivity("erroring_activity_init"); scenario.awaitActivity("activity_init_error");
print("awaited activity"); print("awaited activity");