QRunIO/qqq
2
0
Fork 0
mirror of https://github.com/Kingsrook/qqq.git synced 2025-07-18 05:01:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update to give this test a variable amount of time for its process to finish (updated circleci executor didn't complete in 100ms...)

Browse Source
This commit is contained in:
darin.kelkhoff
2024-02-22 20:23:42 -06:00
parent ed6319ff53
commit edf942a01b
1 changed files with 24 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
qqq-middleware-api/src/test/java/com/kingsrook/qqq/api/utils/ApiScriptUtilsTest.java
View File

@ -44,6 +44,7 @@ import static org.assertj.core.api.Assertions.assertThatThrownBy;
import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull; import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertNull; import static org.junit.jupiter.api.Assertions.assertNull;
import static org.junit.jupiter.api.Assertions.fail;
/******************************************************************************* /*******************************************************************************
@ -334,15 +335,31 @@ class ApiScriptUtilsTest extends BaseTest
String jobId = ValueUtils.getValueAsString(((Map<String, ?>) asyncResult).get("jobId")); String jobId = ValueUtils.getValueAsString(((Map<String, ?>) asyncResult).get("jobId"));
assertNotNull(jobId); assertNotNull(jobId);
SleepUtils.sleep(100, TimeUnit.MILLISECONDS); //////////////////////////////////////////////////////////////////////////////////
// check every 100 ms or so to see if the process is done - but after 10 loops, //
//////////////////////////////////////////////////////////////////////////////////
for(int i = 0; i < 10; i++)
{
Serializable result = apiScriptUtils.getProcessStatus(TestUtils.PROCESS_NAME_TRANSFORM_PEOPLE, jobId);
Serializable result = apiScriptUtils.getProcessStatus(TestUtils.PROCESS_NAME_TRANSFORM_PEOPLE, jobId); if(result instanceof Map map && map.containsKey("jobId"))
assertThat(result).isInstanceOf(List.class); {
List<Map<String, Object>> resultList = (List<Map<String, Object>>) result; System.out.println("Process is still running - sleep and look again...");
assertEquals(3, resultList.size()); SleepUtils.sleep(100, TimeUnit.MILLISECONDS);
continue;
}
assertThat(resultList.stream().filter(m -> m.get("id").equals(2)).findFirst()).isPresent().get().hasFieldOrPropertyWithValue("statusCode", 200); assertThat(result).isInstanceOf(List.class);
assertThat(resultList.stream().filter(m -> m.get("id").equals(3)).findFirst()).isPresent().get().hasFieldOrPropertyWithValue("statusCode", 500); List<Map<String, Object>> resultList = (List<Map<String, Object>>) result;
assertEquals(3, resultList.size());
assertThat(resultList.stream().filter(m -> m.get("id").equals(2)).findFirst()).isPresent().get().hasFieldOrPropertyWithValue("statusCode", 200);
assertThat(resultList.stream().filter(m -> m.get("id").equals(3)).findFirst()).isPresent().get().hasFieldOrPropertyWithValue("statusCode", 500);
return;
}
fail("Process didn't complete after 10 loops, ~1 second.");
} }