diff --git a/fp2_10.py b/fp2_10.py index 67fb35f..3a19e83 100644 --- a/fp2_10.py +++ b/fp2_10.py @@ -52,9 +52,9 @@ with open(file_path, "r") as csv_file: data = ",".join(row).encode("utf-8") try: future = publisher.publish(topic_path, data) + print(f"Published message ID {future.result()}") except DeadlineExceeded as de: print(f"Caught DeadlineExceeded exception: {de}") - print(f"Published message ID {future.result()}") ''' async def receive_messages():