in runinferenceutil/load_data_frombq_pubsub.py [0:0]
def get_callback( publish_future: pubsub_v1.publisher.futures.Future, data: str