|
|
@ -21,15 +21,15 @@ import org.apache.dolphinscheduler.common.Constants; |
|
|
|
import org.apache.dolphinscheduler.common.enums.CommandType; |
|
|
|
import org.apache.dolphinscheduler.common.enums.CommandType; |
|
|
|
import org.apache.dolphinscheduler.common.enums.ExecutionStatus; |
|
|
|
import org.apache.dolphinscheduler.common.enums.ExecutionStatus; |
|
|
|
import org.apache.dolphinscheduler.common.enums.UserType; |
|
|
|
import org.apache.dolphinscheduler.common.enums.UserType; |
|
|
|
import org.apache.dolphinscheduler.common.queue.ITaskQueue; |
|
|
|
|
|
|
|
import org.apache.dolphinscheduler.common.queue.TaskQueueFactory; |
|
|
|
|
|
|
|
import org.apache.dolphinscheduler.common.utils.DateUtils; |
|
|
|
import org.apache.dolphinscheduler.common.utils.DateUtils; |
|
|
|
import org.apache.dolphinscheduler.dao.ProcessDao; |
|
|
|
|
|
|
|
import org.apache.dolphinscheduler.dao.entity.CommandCount; |
|
|
|
import org.apache.dolphinscheduler.dao.entity.CommandCount; |
|
|
|
import org.apache.dolphinscheduler.dao.entity.ExecuteStatusCount; |
|
|
|
import org.apache.dolphinscheduler.dao.entity.ExecuteStatusCount; |
|
|
|
import org.apache.dolphinscheduler.dao.entity.Project; |
|
|
|
import org.apache.dolphinscheduler.dao.entity.Project; |
|
|
|
import org.apache.dolphinscheduler.dao.entity.User; |
|
|
|
import org.apache.dolphinscheduler.dao.entity.User; |
|
|
|
import org.apache.dolphinscheduler.dao.mapper.*; |
|
|
|
import org.apache.dolphinscheduler.dao.mapper.*; |
|
|
|
|
|
|
|
import org.apache.dolphinscheduler.service.process.ProcessService; |
|
|
|
|
|
|
|
import org.apache.dolphinscheduler.service.queue.ITaskQueue; |
|
|
|
|
|
|
|
import org.apache.dolphinscheduler.service.queue.TaskQueueFactory; |
|
|
|
import org.junit.After; |
|
|
|
import org.junit.After; |
|
|
|
import org.junit.Assert; |
|
|
|
import org.junit.Assert; |
|
|
|
import org.junit.Before; |
|
|
|
import org.junit.Before; |
|
|
@ -78,7 +78,7 @@ public class DataAnalysisServiceTest { |
|
|
|
ITaskQueue taskQueue; |
|
|
|
ITaskQueue taskQueue; |
|
|
|
|
|
|
|
|
|
|
|
@Mock |
|
|
|
@Mock |
|
|
|
ProcessDao processDao; |
|
|
|
ProcessService processService; |
|
|
|
|
|
|
|
|
|
|
|
private Project project; |
|
|
|
private Project project; |
|
|
|
|
|
|
|
|
|
|
|