fix deletion of sqs queue regression
@@ -855,13 +855,6 @@ func (s *snsSqs) Subscribe(subscribeCtx context.Context, req pubsub.SubscribeReq
// Remove the handler
delete(s.topicHandlers, sanitizedName)
- // If we can perform management operations, remove the subscription entirely
- if !s.metadata.disableEntityManagement {
- // Use a background context because subscribeCtx is canceled already
- // Error is logged already
- _ = s.removeSnsSqsSubscription(s.ctx, subscriptionArn)
- }
-
// If we don't have any topic left, close the poller
if len(s.topicHandlers) == 0 {
s.pollerCancel()
