@Test
public void testSQSDelayedJob_withDelay() {

  when(asyncClient.add(any(String.class), eq("test-queue"), any(Integer.class)))
      .thenReturn(CompletableFuture.completedFuture(null));
  DyneinJobSpec jobSpec =
      DyneinJobSpec.builder()
          .name("AddJob")
          .queueName("test-queue")
          .schedulePolicy(
              JobSchedulePolicy.builder()
                  .type(JobScheduleType.SQS_DELAYED)
                  .epochMillis(Instant.now().plusMillis(5000L).toEpochMilli())
                  .build())
          .build();
  CompletableFuture<Void> ret = scheduler.createJob(jobSpec);
  verify(asyncClient).add(jobSpecTransformer.serializeJobSpec(jobSpec), "test-queue", 5);
  assertNull(ret.join());
}