diff --git a/shared/database/src/main/kotlin/no/iktdev/mediaprocessing/shared/database/stores/EventStore.kt b/shared/database/src/main/kotlin/no/iktdev/mediaprocessing/shared/database/stores/EventStore.kt index eaf3fc2c..5c2fda97 100644 --- a/shared/database/src/main/kotlin/no/iktdev/mediaprocessing/shared/database/stores/EventStore.kt +++ b/shared/database/src/main/kotlin/no/iktdev/mediaprocessing/shared/database/stores/EventStore.kt @@ -115,6 +115,7 @@ object EventStore: EventStore { } else { log.info { "Identified ${targetedEvent.eventId} in ${targetedEvent.referenceId} as being derived from $taskId" } val preparedDeleteEvent = DeletedTaskResultEvent(targetedEvent.eventId) + .apply { usingReferenceId(targetedEvent.referenceId) } persist(preparedDeleteEvent) return preparedDeleteEvent.deletedEventId }