feat: log the operation name to allow users to check the status (#12773)

* feat: log the operation name to allow users to check the status

* remove blank line

* Add timeout on operation polling level, not the client request

Author: luongadam

managedkafka/snippets/clusters/create_cluster.py

@@ -68,13 +68,13 @@ def create_cluster(
     )
 
     try:
+        operation = client.create_cluster(request=request)
+        print(f"Waiting for operation {operation.operation.name} to complete...")
         # The duration of this operation can vary considerably, typically taking 10-40 minutes.
         # We can set a timeout of 3000s (50 minutes).
-        operation = client.create_cluster(request=request, timeout=3000)
-        print("Waiting for operation to finish...")
-        response = operation.result()
+        response = operation.result(timeout=3000)
         print("Created cluster:", response)
-    except GoogleAPICallError:
-        print("The operation failed with error:", operation.operation.error)
+    except GoogleAPICallError as e:
+        print(f"The operation failed with error: {e.message}")
 
     # [END managedkafka_create_cluster]

managedkafka/snippets/clusters/delete_cluster.py

@@ -47,9 +47,10 @@ def delete_cluster(
 
     try:
         operation = client.delete_cluster(request=request)
+        print(f"Waiting for operation {operation.operation.name} to complete...")
         operation.result()
         print("Deleted cluster")
-    except GoogleAPICallError:
-        print("The operation failed with error:", operation.operation.error)
+    except GoogleAPICallError as e:
+        print(f"The operation failed with error: {e.message}")
 
     # [END managedkafka_delete_cluster]

managedkafka/snippets/clusters/update_cluster.py

@@ -56,9 +56,10 @@ def update_cluster(
 
     try:
         operation = client.update_cluster(request=request)
+        print(f"Waiting for operation {operation.operation.name} to complete...")
         response = operation.result()
         print("Updated cluster:", response)
-    except GoogleAPICallError:
-        print("The operation failed with error:", operation.operation.error)
+    except GoogleAPICallError as e:
+        print(f"The operation failed with error: {e.message}")
 
     # [END managedkafka_update_cluster]