code: def cleanup(self):
          
          if self.subscription:
              logger.info("Deleting worker subscription...")
              self.subscriber_client.delete_subscription(self.subscription)
docs: Deletes this worker's subscription.