diff options
| -rw-r--r-- | src/backend/commands/subscriptioncmds.c | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/backend/commands/subscriptioncmds.c b/src/backend/commands/subscriptioncmds.c index 3b708075653..4353e14e1bd 100644 --- a/src/backend/commands/subscriptioncmds.c +++ b/src/backend/commands/subscriptioncmds.c @@ -514,6 +514,8 @@ DropSubscription(DropSubscriptionStmt *stmt) /* Kill the apply worker so that the slot becomes accessible. */ logicalrep_worker_stop(subid); + LWLockRelease(LogicalRepLauncherLock); + /* Remove the origin tracking if exists. */ snprintf(originname, sizeof(originname), "pg_%u", subid); originid = replorigin_by_name(originname, true); |