@Test(expected = SamzaException.class)
  public void testSamzaJobTimeoutFailureForAsyncTask() {
    InMemorySystemDescriptor isd = new InMemorySystemDescriptor("async-test");

    InMemoryInputDescriptor<Integer> imid = isd
        .getInputDescriptor("ints", new NoOpSerde<>());

    InMemoryOutputDescriptor imod = isd
        .getOutputDescriptor("ints-out", new NoOpSerde<>());

    TestRunner
        .of(MyAsyncStreamTask.class)
        .addInputStream(imid, Arrays.asList(1, 2, 3, 4))
        .addOutputStream(imod, 1)
        .run(Duration.ofMillis(1));
  }
Job should fail because it times out too soon
samza-test/src/test/java/org/apache/samza/test/framework/AsyncStreamTaskIntegrationTest.java