Move future.resuit() into the try block

2023-05-18 14:56:46 -07:00
parent 1ddc498430
commit 09fdbb8b5d
1 changed files with 1 additions and 1 deletions
@@ -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():