def cleanup(self):
    publish_client = pubsub.Client(project=self.project)
    topic = publish_client.topic(self.topic_name)
    if topic.exists():
        topic.delete()
    sub = topic.subscription(self.subscription_name)
    if sub.exists():
        sub.delete()
def cleanup(self):
    publish_client = pubsub.Client(project=self.project)
    topic = publish_client.topic(self.topic_name)
    if topic.exists():
        topic.delete()
    sub = topic.subscription(self.subscription_name)
    if sub.exists():
        sub.delete()