def callback()

in runinferenceutil/load_data_frombq_pubsub.py [0:0]

• 5 lines of code
• 3 McCabe index (conditional complexity)

    def callback(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:
            print(f"Publishing {data} timed out.")