[ERROR] Tests run: 6, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 0.788 s <<< FAILURE! -- in io.aleph0.yap.core.pipeline.PipelineManagerTest
[ERROR] io.aleph0.yap.core.pipeline.PipelineManagerTest.givenRunningPipeline_whenInterrupted_thenCancelsAllTasks -- Time elapsed: 0.015 s <<< FAILURE!
java.lang.AssertionError:
Expecting UnmodifiableRandomAccessList:
[EventOrAction[event=null, action=StartTaskPipelineAction[id=task3]],
EventOrAction[event=TaskStartedEvent[id=task3], action=null],
EventOrAction[event=null, action=StartTaskPipelineAction[id=task2]],
EventOrAction[event=TaskStartedEvent[id=task2], action=null],
EventOrAction[event=null, action=StartTaskPipelineAction[id=task1]],
EventOrAction[event=TaskStartedEvent[id=task1], action=null],
EventOrAction[event=WorkerLifecycleEvent[taskId=task3, workerId=0, event=io.aleph0.yap.core.pipeline.PipelineManager$WorkerLifecycleListener$$Lambda/0x000007ff011874f0@6f43c82], action=null],
EventOrAction[event=WorkerLifecycleEvent[taskId=task2, workerId=0, event=io.aleph0.yap.core.pipeline.PipelineManager$WorkerLifecycleListener$$Lambda/0x000007ff011874f0@5db6b9cd], action=null],
EventOrAction[event=WorkerLifecycleEvent[taskId=task1, workerId=0, event=io.aleph0.yap.core.pipeline.PipelineManager$WorkerLifecycleListener$$Lambda/0x000007ff011874f0@210ab13f], action=null],
EventOrAction[event=null, action=CancelTaskPipelineAction[id=task3]],
EventOrAction[event=null, action=CancelTaskPipelineAction[id=task2]],
EventOrAction[event=null, action=CancelTaskPipelineAction[id=task1]]]
to contain:
[EventOrAction[event=null, action=StartTaskPipelineAction[id=task3]],
EventOrAction[event=TaskStartedEvent[id=task3], action=null],
EventOrAction[event=null, action=StartTaskPipelineAction[id=task2]],
EventOrAction[event=TaskStartedEvent[id=task2], action=null],
EventOrAction[event=null, action=StartTaskPipelineAction[id=task1]],
EventOrAction[event=TaskStartedEvent[id=task1], action=null],
EventOrAction[event=null, action=CancelTaskPipelineAction[id=task1]],
EventOrAction[event=TaskCancelledEvent[id=task1], action=null],
EventOrAction[event=null, action=CancelTaskPipelineAction[id=task2]],
EventOrAction[event=TaskCancelledEvent[id=task2], action=null],
EventOrAction[event=null, action=CancelTaskPipelineAction[id=task3]],
EventOrAction[event=TaskCancelledEvent[id=task3], action=null],
EventOrAction[event=null, action=CancelPipelineAction[]]]
but could not find the following element(s):
[EventOrAction[event=TaskCancelledEvent[id=task1], action=null],
EventOrAction[event=TaskCancelledEvent[id=task2], action=null],
EventOrAction[event=TaskCancelledEvent[id=task3], action=null],
EventOrAction[event=null, action=CancelPipelineAction[]]]
at io.aleph0.yap.core.pipeline.PipelineManagerTest.givenRunningPipeline_whenInterrupted_thenCancelsAllTasks(PipelineManagerTest.java:231)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1597)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1597)
