From d0a8f401409b9c1025d5656835ada29b7080ef9d Mon Sep 17 00:00:00 2001
From: Chris Gwilliams <517923+encima@users.noreply.github.com>
Date: Wed, 2 Apr 2025 12:42:15 +0300
Subject: [PATCH 1/2] add migration for pg_create_subscription grant

---
 ..._grant_subscription_to_postgres_16_and_above.sql | 13 +++++++++++++
 1 file changed, 13 insertions(+)
 create mode 100644 migrations/db/migrations/20250402093753_grant_subscription_to_postgres_16_and_above.sql

diff --git a/migrations/db/migrations/20250402093753_grant_subscription_to_postgres_16_and_above.sql b/migrations/db/migrations/20250402093753_grant_subscription_to_postgres_16_and_above.sql
new file mode 100644
index 000000000..0472783e4
--- /dev/null
+++ b/migrations/db/migrations/20250402093753_grant_subscription_to_postgres_16_and_above.sql
@@ -0,0 +1,13 @@
+-- migrate:up
+DO $$
+DECLARE
+  major_version INT;
+BEGIN
+  SELECT current_setting('server_version_num')::INT / 10000 INTO major_version;
+
+  IF major_version >= 16 THEN
+    GRANT pg_create_subscription TO postgres;
+  END IF;
+END $$;
+
+-- migrate:down
\ No newline at end of file

From b1d303cd93dc7aed909145ba975ed0324472b69f Mon Sep 17 00:00:00 2001
From: Bobbie Soedirgo <31685197+soedirgo@users.noreply.github.com>
Date: Fri, 4 Apr 2025 01:59:01 +0800
Subject: [PATCH 2/2] Update
 migrations/db/migrations/20250402093753_grant_subscription_to_postgres_16_and_above.sql

---
 ...250402093753_grant_subscription_to_postgres_16_and_above.sql | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/migrations/db/migrations/20250402093753_grant_subscription_to_postgres_16_and_above.sql b/migrations/db/migrations/20250402093753_grant_subscription_to_postgres_16_and_above.sql
index 0472783e4..9e9d881ae 100644
--- a/migrations/db/migrations/20250402093753_grant_subscription_to_postgres_16_and_above.sql
+++ b/migrations/db/migrations/20250402093753_grant_subscription_to_postgres_16_and_above.sql
@@ -10,4 +10,4 @@ BEGIN
   END IF;
 END $$;
 
--- migrate:down
\ No newline at end of file
+-- migrate:down