in transcoder/output/google_cloud/PubSubOutputManager.py [0:0]
def __delete_schema(self, schema_path):
try:
self.schema_client.delete_schema(request={"name": schema_path})
logging.debug('Deleted a schema:\n%s', schema_path)
return True
except NotFound:
logging.debug('%s not found.', schema_path)
return False