Closed mukund-ananthu closed 9 months ago
Run the code example provided on a valid topic and project.
from google.cloud import pubsub_v1 from google.api_core.exceptions import InvalidArgument publisher = pubsub_v1.PublisherClient() topic_path = publisher.topic_path( "project-id", "topic-name" ) payload = b"test-message" try: future = publisher.publish( topic=topic_path, data=payload, ) print(future.result()) except InvalidArgument: print("Caught error: Message failed schema validation")
Caught error: Message failed schema validation Failed to publish 1 messages. Traceback (most recent call last): ... rest of traceback
Steps to reproduce
Run the code example provided on a valid topic and project.
Code example
Stack trace