def _get_or_create_subscription(self):
topic_path = self._get_topic_path()<EOL>subscription_name = '<STR_LIT>'.format(<EOL>queue.PUBSUB_OBJECT_PREFIX, self.name, uuid4().hex)<EOL>subscription_path = self.subscriber_client.subscription_path(<EOL>self.project, subscription_name)<EOL>try:<EOL><INDENT>self.subscriber_client.get_subscription(subscription_path)<EOL><DEDENT>except google.cloud.exceptions.NotFound:<EOL><INDENT>logger.info("<STR_LIT>".format(<EOL>subscription_name))<EOL>self.subscriber_client.create_subscription(<EOL>subscription_path, topic_path)<EOL><DEDENT>return subscription_path<EOL>
In a broadcast queue, workers have a unique subscription ensuring
        that every worker recieves a copy of every task.