in check-blogs/main.py [0:0]
def publish_to_pubsub(space_id, blog):
"""Publishes a message to Pub/Sub with space ID and HTML content."""
message_json = json.dumps(
{
"space_id": space_id,
"blog": blog,
}
).encode("utf-8")
future = publisher.publish(topic_path, message_json)
future.add_done_callback(callback)
publish_futures.append(future)
print(f"Published message ID: {future.result()}")