diff --git a/packages/sync-engine/src/database/migrations/0003_prices.sql b/packages/sync-engine/src/database/migrations/0003_prices.sql
index e133637ab..a6cd19437 100644
--- a/packages/sync-engine/src/database/migrations/0003_prices.sql
+++ b/packages/sync-engine/src/database/migrations/0003_prices.sql
@@ -1,9 +1,9 @@
 DO $$
 BEGIN
-    IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'pricing_type') THEN
+    IF NOT EXISTS (SELECT 1 FROM pg_type t JOIN pg_namespace n ON n.oid = t.typnamespace WHERE t.typname = 'pricing_type' AND n.nspname = 'stripe') THEN
         create type "stripe"."pricing_type" as enum ('one_time', 'recurring');
     END IF;
-    IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'pricing_tiers') THEN
+    IF NOT EXISTS (SELECT 1 FROM pg_type t JOIN pg_namespace n ON n.oid = t.typnamespace WHERE t.typname = 'pricing_tiers' AND n.nspname = 'stripe') THEN
       create type "stripe"."pricing_tiers" as enum ('graduated', 'volume');
     END IF;
     --more types here...
diff --git a/packages/sync-engine/src/database/migrations/0004_subscriptions.sql b/packages/sync-engine/src/database/migrations/0004_subscriptions.sql
index bd9e57535..c6e4ea190 100644
--- a/packages/sync-engine/src/database/migrations/0004_subscriptions.sql
+++ b/packages/sync-engine/src/database/migrations/0004_subscriptions.sql
@@ -1,7 +1,7 @@
 
 DO $$
 BEGIN
-    IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'subscription_status') THEN
+    IF NOT EXISTS (SELECT 1 FROM pg_type t JOIN pg_namespace n ON n.oid = t.typnamespace WHERE t.typname = 'subscription_status' AND n.nspname = 'stripe') THEN
         create type "stripe"."subscription_status" as enum (
           'trialing',
           'active',
diff --git a/packages/sync-engine/src/database/migrations/0005_invoices.sql b/packages/sync-engine/src/database/migrations/0005_invoices.sql
index 0b664eda9..ba5f6cdf2 100644
--- a/packages/sync-engine/src/database/migrations/0005_invoices.sql
+++ b/packages/sync-engine/src/database/migrations/0005_invoices.sql
@@ -1,7 +1,7 @@
 
 DO $$
 BEGIN
-    IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'invoice_status') THEN
+    IF NOT EXISTS (SELECT 1 FROM pg_type t JOIN pg_namespace n ON n.oid = t.typnamespace WHERE t.typname = 'invoice_status' AND n.nspname = 'stripe') THEN
         create type "stripe"."invoice_status" as enum ('draft', 'open', 'paid', 'uncollectible', 'void');
     END IF;
 END
diff --git a/packages/sync-engine/src/database/migrations/0024_subscription_schedules.sql b/packages/sync-engine/src/database/migrations/0024_subscription_schedules.sql
index a095509bc..6a4e8a31e 100644
--- a/packages/sync-engine/src/database/migrations/0024_subscription_schedules.sql
+++ b/packages/sync-engine/src/database/migrations/0024_subscription_schedules.sql
@@ -1,6 +1,6 @@
 do $$
 BEGIN
-    IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'subscription_schedule_status') THEN
+    IF NOT EXISTS (SELECT 1 FROM pg_type t JOIN pg_namespace n ON n.oid = t.typnamespace WHERE t.typname = 'subscription_schedule_status' AND n.nspname = 'stripe') THEN
         create type "stripe"."subscription_schedule_status" as enum ('not_started', 'active', 'completed', 'released', 'canceled');
     END IF;
 END