nosu
/
taskana
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

TSK-882: Insert short breaks to avoid getting the same timestamp

This commit is contained in:
BVier 2019-09-18 10:21:35 +02:00 committed by Dennis Lehmann
parent 6a2ef47cbd
commit 78745e4de1
1 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
lib/taskana-core/src/test/java/acceptance/task/CompleteTaskAccTest.java
View File

@ -89,6 +89,7 @@ public class CompleteTaskAccTest extends AbstractAccTest {
newTaskImpl.setClaimed(Instant.now()); newTaskImpl.setClaimed(Instant.now());
Task createdTask = taskService.createTask(newTaskImpl); Task createdTask = taskService.createTask(newTaskImpl);
waitAMillisecond();
Task completedTask = taskService.forceCompleteTask(createdTask.getId()); Task completedTask = taskService.forceCompleteTask(createdTask.getId());
assertEquals(TaskState.COMPLETED, completedTask.getState()); assertEquals(TaskState.COMPLETED, completedTask.getState());
@ -115,6 +116,7 @@ public class CompleteTaskAccTest extends AbstractAccTest {
newTaskImpl.setClaimed(Instant.now()); newTaskImpl.setClaimed(Instant.now());
Task createdTask = taskService.createTask(newTaskImpl); Task createdTask = taskService.createTask(newTaskImpl);
waitAMillisecond();
Task completedTask = taskService.forceCompleteTask(createdTask.getId()); Task completedTask = taskService.forceCompleteTask(createdTask.getId());
assertEquals(TaskState.COMPLETED, completedTask.getState()); assertEquals(TaskState.COMPLETED, completedTask.getState());
@ -174,12 +176,9 @@ public class CompleteTaskAccTest extends AbstractAccTest {
assertNull(createdTask.getClaimed()); assertNull(createdTask.getClaimed());
Instant before = Instant.now(); Instant before = Instant.now();
waitAMillisecond();
Task claimedTask = taskService.claim(createdTask.getId()); Task claimedTask = taskService.claim(createdTask.getId());
try { waitAMillisecond();
TimeUnit.MILLISECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
Instant after = Instant.now(); Instant after = Instant.now();
assertNotNull(claimedTask.getOwner()); assertNotNull(claimedTask.getOwner());
@ -210,6 +209,7 @@ public class CompleteTaskAccTest extends AbstractAccTest {
assertNotNull(createdTask); assertNotNull(createdTask);
assertEquals(createdTask.getOwner(), "other_user"); assertEquals(createdTask.getOwner(), "other_user");
waitAMillisecond();
Instant beforeForceClaim = Instant.now(); Instant beforeForceClaim = Instant.now();
Task taskAfterClaim = taskService.forceClaim(createdTask.getId()); Task taskAfterClaim = taskService.forceClaim(createdTask.getId());
@ -335,4 +335,11 @@ public class CompleteTaskAccTest extends AbstractAccTest {
taskService.cancelClaim("TKI:000000000000000000000000000000000100"); taskService.cancelClaim("TKI:000000000000000000000000000000000100");
} }
private void waitAMillisecond() {
try {
TimeUnit.MILLISECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
} }