@Test
public void testTaskRequiredMigration() {

    Task job1Task0 = jobOperations.getTasks("job1").get(0);
    dataGenerator.place("active1", job1Task0);
    dataGenerator.setQuota("job1", 1);
    dataGenerator.addTaskAttribute(job1Task0.getId(), RelocationAttributes.RELOCATION_REQUIRED, "true");
    clock.advanceTime(Duration.ofSeconds(1));
    Map<String, DeschedulingResult> results = newDescheduler(Collections.emptyMap()).findRequestedJobOrTaskMigrations();
    assertThat(results).isNotEmpty();
}