index c29a57ed52d2bb4c9bc7045b00213e23821b007c..6a404bbe1e3d18be28fad1a325e3466ae87fc45f 100644 (file)
@@ -644,6 +644,9 @@ AlterSubscription(AlterSubscriptionStmt *stmt)
BoolGetDatum(enabled);
replaces[Anum_pg_subscription_subenabled - 1] = true;
+ if (enabled)
+ ApplyLauncherWakeupAtCommit();
+
update_tuple = true;
break;
}