diff --git a/server/services/triggers.js b/server/services/triggers.js
index 0b44712a..e4b98b6f 100644
--- a/server/services/triggers.js
+++ b/server/services/triggers.js
@@ -52,6 +52,7 @@ async function run() {
                     .where(function () {
                         addSegmentQuery(this);
                     })
+                    .where(subsTable + '.status', SubscriptionStatus.SUBSCRIBED)
                     .whereNull('related_trigger_messages.id') // This means only those where the trigger has not fired yet somewhen in the past
                     .select(subsTable + '.id');