diff --git a/src/main/kotlin/db/migration/V150__dvh_use_codes.kt b/src/main/kotlin/db/migration/V150__dvh_use_codes.kt
index 9b8274edf..358e395fe 100644
--- a/src/main/kotlin/db/migration/V150__dvh_use_codes.kt
+++ b/src/main/kotlin/db/migration/V150__dvh_use_codes.kt
@@ -31,6 +31,7 @@ class V150__dvh_use_codes : BaseJavaMigration() {
                 """
                     select ke.id, ke.json_payload
                     from klage.kafka_event ke
+                    where ke.type = 'STATS_DVH'
                     order by ke.created
                 """
             )