diff --git a/kong/db/migrations/core/025_390_to_3100.lua b/kong/db/migrations/core/025_390_to_3100.lua
index 3c7cf1186997..8af90e46c83c 100644
--- a/kong/db/migrations/core/025_390_to_3100.lua
+++ b/kong/db/migrations/core/025_390_to_3100.lua
@@ -2,6 +2,7 @@ return {
   postgres = {
     up = [[
       DO $$
+      BEGIN
       DROP TABLE IF EXISTS clustering_sync_delta;
       DROP INDEX IF EXISTS clustering_sync_delta_version_idx;
       END;