diff --git a/engine/src/test/java/io/camunda/zeebe/engine/processing/timer/TimerStartEventTest.java b/engine/src/test/java/io/camunda/zeebe/engine/processing/timer/TimerStartEventTest.java index d51c4fa001fd..43ea3df87a0d 100644 --- a/engine/src/test/java/io/camunda/zeebe/engine/processing/timer/TimerStartEventTest.java +++ b/engine/src/test/java/io/camunda/zeebe/engine/processing/timer/TimerStartEventTest.java @@ -356,27 +356,25 @@ public void shouldTriggerAndCreateProcessInstance() { .hasVersion(deployedProcess.getVersion()) .hasProcessDefinitionKey(processDefinitionKey); - final long triggerRecordPosition = - RecordingExporter.timerRecords(TimerIntent.TRIGGER) + final var processInstanceKey = + RecordingExporter.processInstanceRecords(ProcessInstanceIntent.ELEMENT_ACTIVATED) .withProcessDefinitionKey(processDefinitionKey) .getFirst() - .getPosition(); + .getValue() + .getProcessInstanceKey(); assertThat( - RecordingExporter.timerRecords() - .withProcessDefinitionKey(processDefinitionKey) - .skipUntil(r -> r.getPosition() >= triggerRecordPosition) - .limit(2)) - .extracting(Record::getIntent) - .containsExactly(TimerIntent.TRIGGER, TimerIntent.TRIGGERED); + RecordingExporter.timerRecords(TimerIntent.TRIGGERED) + .withProcessInstanceKey(processInstanceKey) + .exists()) + .isTrue(); assertThat( RecordingExporter.processInstanceRecords() .withProcessDefinitionKey(processDefinitionKey) - .skipUntil(r -> r.getPosition() >= triggerRecordPosition) - .limit(4)) + .limitToProcessInstanceCompleted()) .extracting(r -> r.getValue().getBpmnElementType(), Record::getIntent) - .containsExactly( + .containsSequence( tuple(BpmnElementType.PROCESS, ProcessInstanceIntent.ACTIVATE_ELEMENT), tuple(BpmnElementType.PROCESS, ProcessInstanceIntent.ELEMENT_ACTIVATING), tuple(BpmnElementType.PROCESS, ProcessInstanceIntent.ELEMENT_ACTIVATED),