SpringCloud/spring-cloud-task
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Implement getRunningTaskCount

Browse Source 
Expose functionality via TaskExplorer

Polishing on merge
This commit is contained in:
David Turanski
2018-07-10 16:42:10 -04:00
committed by Glenn Renfro
parent 1406fa986c
commit cba26ed968
7 changed files with 69 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
spring-cloud-task-core/src/test/java/org/springframework/cloud/task/repository/dao/BaseTaskExecutionDaoTestCases.java
View File

@@ -239,6 +239,15 @@ public class BaseTaskExecutionDaoTestCases {
assertEquals(9 + executionIdOffset, latestTaskExecution.getExecutionId());
}
@Test
@DirtiesContext
public void getRunningTaskExecutions() {
initializeRepositoryNotInOrderWithMultipleTaskExecutions();
assertEquals(dao.getTaskExecutionCount(), dao.getRunningTaskExecutionCount());
dao.completeTaskExecution(1, 0, new Date(), "c'est fini!" );
assertEquals(dao.getTaskExecutionCount() - 1, dao.getRunningTaskExecutionCount());
}
protected long initializeRepositoryNotInOrderWithMultipleTaskExecutions() {
final TaskExecution foo1_0 = getTaskExecution("FOO1", "externalC");

9
spring-cloud-task-core/src/test/java/org/springframework/cloud/task/repository/support/SimpleTaskExplorerTests.java
View File

@@ -154,6 +154,15 @@ public class SimpleTaskExplorerTests {
33, taskExplorer.getTaskExecutionCount());
}
@Test
public void getRunningTaskCount() {
createSampleDataSet(33);
assertEquals(String.format(
"task count did not match expected result for test Type %s",
testType),
33, taskExplorer.getRunningTaskExecutionCount());
}
@Test
public void findRunningTasks() {
final int TEST_COUNT = 2;