dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix test whenTenantIsDeleted_thenCancelAllTheJobs

Browse Source
This commit is contained in:
ViacheslavKlimov 2025-05-15 11:11:40 +03:00
parent 55da7ac2b6
commit 8dda445253
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
application/src/test/java/org/thingsboard/server/service/job/JobManagerTest.java
View File

@ -27,13 +27,16 @@ import org.thingsboard.server.common.data.id.JobId;
import org.thingsboard.server.common.data.id.TenantId; import org.thingsboard.server.common.data.id.TenantId;
import org.thingsboard.server.common.data.job.DummyJobConfiguration; import org.thingsboard.server.common.data.job.DummyJobConfiguration;
import org.thingsboard.server.common.data.job.Job; import org.thingsboard.server.common.data.job.Job;
import org.thingsboard.server.common.data.job.JobFilter;
import org.thingsboard.server.common.data.job.JobResult; import org.thingsboard.server.common.data.job.JobResult;
import org.thingsboard.server.common.data.job.JobStatus; import org.thingsboard.server.common.data.job.JobStatus;
import org.thingsboard.server.common.data.job.JobType; import org.thingsboard.server.common.data.job.JobType;
import org.thingsboard.server.common.data.job.task.DummyTaskResult; import org.thingsboard.server.common.data.job.task.DummyTaskResult;
import org.thingsboard.server.common.data.job.task.DummyTaskResult.DummyTaskFailure; import org.thingsboard.server.common.data.job.task.DummyTaskResult.DummyTaskFailure;
import org.thingsboard.server.common.data.notification.Notification; import org.thingsboard.server.common.data.notification.Notification;
import org.thingsboard.server.common.data.page.PageLink;
import org.thingsboard.server.controller.AbstractControllerTest; import org.thingsboard.server.controller.AbstractControllerTest;
import org.thingsboard.server.dao.job.JobService;
import org.thingsboard.server.dao.service.DaoSqlTest; import org.thingsboard.server.dao.service.DaoSqlTest;
import org.thingsboard.server.queue.task.JobStatsService; import org.thingsboard.server.queue.task.JobStatsService;
@ -65,6 +68,9 @@ public class JobManagerTest extends AbstractControllerTest {
@SpyBean @SpyBean
private JobStatsService jobStatsService; private JobStatsService jobStatsService;
@Autowired
private JobService jobService;
@Before @Before
public void setUp() throws Exception { public void setUp() throws Exception {
loginTenantAdmin(); loginTenantAdmin();
@ -250,7 +256,7 @@ public class JobManagerTest extends AbstractControllerTest {
Thread.sleep(3000); Thread.sleep(3000);
verify(jobStatsService, never()).reportTaskResult(any(), any(), any()); verify(jobStatsService, never()).reportTaskResult(any(), any(), any());
assertThat(findJobs()).isEmpty(); assertThat(jobService.findJobsByFilter(tenantId, JobFilter.builder().build(), new PageLink(100)).getData()).isEmpty();
} }
@Test @Test