def METHOD_NAME(publish_future: pubsub_v1.publisher.futures.Future) -> None:
    try:
        # Wait 60 seconds for the publish call to succeed.
        print(publish_future.result(timeout=60))
    except futures.TimeoutError:
        logging.error(f"Publishing {data} timed out.")