in check-release-notes/main.py [0:0]
def publish_to_pubsub(space_id, release_note):
"""Publishes a message to Pub/Sub with space ID and HTML content."""
message_json = json.dumps(
{
"space_id": space_id,
"release_note": release_note,
}
).encode("utf-8")
future = publisher.publish(topic_path, message_json)
# Non-blocking. Allow the publisher client to batch multiple messages.
future.add_done_callback(callback)
publish_futures.append(future)
print(f"Published message ID: {future.result()}")