def create_topic()

in python-batch/batch.py [0:0]


  def create_topic(self):
    """
    Creates a topic with name the same as Job.

    The `topic_path` method creates a fully qualified identifier
    in the form `projects/{project_id}/topics/{topic_id}`

    Args:
      None

    Returns:
      None
    """
    self.topic_path = self.publisher.topic_path(self.project_id, self.job_id)
    self.topic = self.publisher.create_topic(request={"name": self.topic_path})
    print(f"Created topic {self.topic_path}\n", file=sys.stderr)