diff --git a/dolphinscheduler-service/src/test/java/org/apache/dolphinscheduler/service/process/ProcessServiceTest.java b/dolphinscheduler-service/src/test/java/org/apache/dolphinscheduler/service/process/ProcessServiceTest.java index 999ca46a4e..a693c2e6d8 100644 --- a/dolphinscheduler-service/src/test/java/org/apache/dolphinscheduler/service/process/ProcessServiceTest.java +++ b/dolphinscheduler-service/src/test/java/org/apache/dolphinscheduler/service/process/ProcessServiceTest.java @@ -464,4 +464,17 @@ public class ProcessServiceTest { processService.changeOutParam(result,taskInstance); } + @Test + public void testCreateCommand() { + Command command = new Command(); + command.setProcessDefinitionId(123); + command.setCommandParam("{\"ProcessInstanceId\":222}"); + command.setCommandType(CommandType.START_PROCESS); + int mockResult = 1; + Mockito.when(commandMapper.insert(command)).thenReturn(mockResult); + int exeMethodResult = processService.createCommand(command); + Assert.assertEquals(mockResult, exeMethodResult); + Mockito.verify(commandMapper, Mockito.times(1)).insert(command); + } + }