fix(docs): async samples missing await

gapic/templates/examples/feature_fragments.j2

@@ -230,7 +230,7 @@ request=request
 {# Note: this doesn't deal with enums or unions #}
 {# LROs return operation objects and paged requests return pager objects #}
 {% if transport == "grpc-async" and calling_form not in
-[calling_form_enum.LongRunningRequestPromise, calling_form_enum.RequestPagedAll] %}
+[calling_form_enum.RequestPaged, calling_form_enum.RequestPagedAll] %}
 await{{ " "}}
 {%- endif -%}
 {% if calling_form in [calling_form_enum.RequestStreamingBidi,
@@ -242,13 +242,6 @@ client.{{ render_method_name(sample)|trim }}({{ render_request_params_unary(samp
 {% endif %}
 {% endmacro %}
 
-{% macro operation_text(transport) %}
-{% if transport == "grpc-async" %}
-(await operation)
-{% else %}
-operation
-{% endif %}
-{% endmacro %}
 
 {# Setting up the method invocation is the responsibility of the caller: #}
 {# it's just easier to set up client side streaming and other things from outside this macro. #}
@@ -294,9 +287,7 @@ operation = {{ method_invocation_text|trim }}
 
 print("Waiting for operation to complete...")
 
-{% with operation_text = operation_text(transport) %}
-response = {{ operation_text|trim }}.result()
-{% endwith %}
+response = {% if transport == "grpc-async" %}await {% endif %}operation.result()
 
 # Handle the response
 {% for statement in response_statements %}

tests/integration/goldens/asset/google/cloud/asset_v1/services/asset_service/async_client.py

@@ -322,11 +322,11 @@ async def sample_export_assets():
                 )
 
                 # Make the request
-                operation = client.export_assets(request=request)
+                operation = await client.export_assets(request=request)
 
                 print("Waiting for operation to complete...")
 
-                response = (await operation).result()
+                response = await operation.result()
 
                 # Handle the response
                 print(response)
@@ -1727,11 +1727,11 @@ async def sample_analyze_iam_policy_longrunning():
                 )
 
                 # Make the request
-                operation = client.analyze_iam_policy_longrunning(request=request)
+                operation = await client.analyze_iam_policy_longrunning(request=request)
 
                 print("Waiting for operation to complete...")
 
-                response = (await operation).result()
+                response = await operation.result()
 
                 # Handle the response
                 print(response)

tests/integration/goldens/asset/samples/generated_samples/cloudasset_v1_generated_asset_service_analyze_iam_policy_longrunning_async.py

@@ -51,11 +51,11 @@ async def sample_analyze_iam_policy_longrunning():
     )
 
     # Make the request
-    operation = client.analyze_iam_policy_longrunning(request=request)
+    operation = await client.analyze_iam_policy_longrunning(request=request)
 
     print("Waiting for operation to complete...")
 
-    response = (await operation).result()
+    response = await operation.result()
 
     # Handle the response
     print(response)

tests/integration/goldens/asset/samples/generated_samples/cloudasset_v1_generated_asset_service_export_assets_async.py

@@ -48,11 +48,11 @@ async def sample_export_assets():
     )
 
     # Make the request
-    operation = client.export_assets(request=request)
+    operation = await client.export_assets(request=request)
 
     print("Waiting for operation to complete...")
 
-    response = (await operation).result()
+    response = await operation.result()
 
     # Handle the response
     print(response)

tests/integration/goldens/eventarc/google/cloud/eventarc_v1/services/eventarc/async_client.py

@@ -564,11 +564,11 @@ async def sample_create_trigger():
                 )
 
                 # Make the request
-                operation = client.create_trigger(request=request)
+                operation = await client.create_trigger(request=request)
 
                 print("Waiting for operation to complete...")
 
-                response = (await operation).result()
+                response = await operation.result()
 
                 # Handle the response
                 print(response)
@@ -703,11 +703,11 @@ async def sample_update_trigger():
                 )
 
                 # Make the request
-                operation = client.update_trigger(request=request)
+                operation = await client.update_trigger(request=request)
 
                 print("Waiting for operation to complete...")
 
-                response = (await operation).result()
+                response = await operation.result()
 
                 # Handle the response
                 print(response)
@@ -845,11 +845,11 @@ async def sample_delete_trigger():
                 )
 
                 # Make the request
-                operation = client.delete_trigger(request=request)
+                operation = await client.delete_trigger(request=request)
 
                 print("Waiting for operation to complete...")
 
-                response = (await operation).result()
+                response = await operation.result()
 
                 # Handle the response
                 print(response)
@@ -1218,11 +1218,11 @@ async def sample_create_channel():
                 )
 
                 # Make the request
-                operation = client.create_channel(request=request)
+                operation = await client.create_channel(request=request)
 
                 print("Waiting for operation to complete...")
 
-                response = (await operation).result()
+                response = await operation.result()
 
                 # Handle the response
                 print(response)
@@ -1359,11 +1359,11 @@ async def sample_update_channel():
                 )
 
                 # Make the request
-                operation = client.update_channel(request=request)
+                operation = await client.update_channel(request=request)
 
                 print("Waiting for operation to complete...")
 
-                response = (await operation).result()
+                response = await operation.result()
 
                 # Handle the response
                 print(response)
@@ -1493,11 +1493,11 @@ async def sample_delete_channel():
                 )
 
                 # Make the request
-                operation = client.delete_channel(request=request)
+                operation = await client.delete_channel(request=request)
 
                 print("Waiting for operation to complete...")
 
-                response = (await operation).result()
+                response = await operation.result()
 
                 # Handle the response
                 print(response)
@@ -2084,11 +2084,11 @@ async def sample_create_channel_connection():
                 )
 
                 # Make the request
-                operation = client.create_channel_connection(request=request)
+                operation = await client.create_channel_connection(request=request)
 
                 print("Waiting for operation to complete...")
 
-                response = (await operation).result()
+                response = await operation.result()
 
                 # Handle the response
                 print(response)
@@ -2225,11 +2225,11 @@ async def sample_delete_channel_connection():
                 )
 
                 # Make the request
-                operation = client.delete_channel_connection(request=request)
+                operation = await client.delete_channel_connection(request=request)
 
                 print("Waiting for operation to complete...")
 
-                response = (await operation).result()
+                response = await operation.result()
 
                 # Handle the response
                 print(response)

tests/integration/goldens/eventarc/samples/generated_samples/eventarc_v1_generated_eventarc_create_channel_async.py

@@ -51,11 +51,11 @@ async def sample_create_channel():
     )
 
     # Make the request
-    operation = client.create_channel(request=request)
+    operation = await client.create_channel(request=request)
 
     print("Waiting for operation to complete...")
 
-    response = (await operation).result()
+    response = await operation.result()
 
     # Handle the response
     print(response)

tests/integration/goldens/eventarc/samples/generated_samples/eventarc_v1_generated_eventarc_create_channel_connection_async.py

@@ -50,11 +50,11 @@ async def sample_create_channel_connection():
     )
 
     # Make the request
-    operation = client.create_channel_connection(request=request)
+    operation = await client.create_channel_connection(request=request)
 
     print("Waiting for operation to complete...")
 
-    response = (await operation).result()
+    response = await operation.result()
 
     # Handle the response
     print(response)

tests/integration/goldens/eventarc/samples/generated_samples/eventarc_v1_generated_eventarc_create_trigger_async.py

@@ -54,11 +54,11 @@ async def sample_create_trigger():
     )
 
     # Make the request
-    operation = client.create_trigger(request=request)
+    operation = await client.create_trigger(request=request)
 
     print("Waiting for operation to complete...")
 
-    response = (await operation).result()
+    response = await operation.result()
 
     # Handle the response
     print(response)

tests/integration/goldens/eventarc/samples/generated_samples/eventarc_v1_generated_eventarc_delete_channel_async.py

@@ -45,11 +45,11 @@ async def sample_delete_channel():
     )
 
     # Make the request
-    operation = client.delete_channel(request=request)
+    operation = await client.delete_channel(request=request)
 
     print("Waiting for operation to complete...")
 
-    response = (await operation).result()
+    response = await operation.result()
 
     # Handle the response
     print(response)

tests/integration/goldens/eventarc/samples/generated_samples/eventarc_v1_generated_eventarc_delete_channel_connection_async.py

@@ -44,11 +44,11 @@ async def sample_delete_channel_connection():
     )
 
     # Make the request
-    operation = client.delete_channel_connection(request=request)
+    operation = await client.delete_channel_connection(request=request)
 
     print("Waiting for operation to complete...")
 
-    response = (await operation).result()
+    response = await operation.result()
 
     # Handle the response
     print(response)

tests/integration/goldens/eventarc/samples/generated_samples/eventarc_v1_generated_eventarc_delete_trigger_async.py

@@ -45,11 +45,11 @@ async def sample_delete_trigger():
     )
 
     # Make the request
-    operation = client.delete_trigger(request=request)
+    operation = await client.delete_trigger(request=request)
 
     print("Waiting for operation to complete...")
 
-    response = (await operation).result()
+    response = await operation.result()
 
     # Handle the response
     print(response)

tests/integration/goldens/eventarc/samples/generated_samples/eventarc_v1_generated_eventarc_update_channel_async.py

@@ -44,11 +44,11 @@ async def sample_update_channel():
     )
 
     # Make the request
-    operation = client.update_channel(request=request)
+    operation = await client.update_channel(request=request)
 
     print("Waiting for operation to complete...")
 
-    response = (await operation).result()
+    response = await operation.result()
 
     # Handle the response
     print(response)

tests/integration/goldens/eventarc/samples/generated_samples/eventarc_v1_generated_eventarc_update_trigger_async.py

@@ -44,11 +44,11 @@ async def sample_update_trigger():
     )
 
     # Make the request
-    operation = client.update_trigger(request=request)
+    operation = await client.update_trigger(request=request)
 
     print("Waiting for operation to complete...")
 
-    response = (await operation).result()
+    response = await operation.result()
 
     # Handle the response
     print(response)

tests/integration/goldens/logging/google/cloud/logging_v2/services/config_service_v2/async_client.py

@@ -520,11 +520,11 @@ async def sample_create_bucket_async():
                 )
 
                 # Make the request
-                operation = client.create_bucket_async(request=request)
+                operation = await client.create_bucket_async(request=request)
 
                 print("Waiting for operation to complete...")
 
-                response = (await operation).result()
+                response = await operation.result()
 
                 # Handle the response
                 print(response)
@@ -625,11 +625,11 @@ async def sample_update_bucket_async():
                 )
 
                 # Make the request
-                operation = client.update_bucket_async(request=request)
+                operation = await client.update_bucket_async(request=request)
 
                 print("Waiting for operation to complete...")
 
-                response = (await operation).result()
+                response = await operation.result()
 
                 # Handle the response
                 print(response)
@@ -2177,11 +2177,11 @@ async def sample_create_link():
                 )
 
                 # Make the request
-                operation = client.create_link(request=request)
+                operation = await client.create_link(request=request)
 
                 print("Waiting for operation to complete...")
 
-                response = (await operation).result()
+                response = await operation.result()
 
                 # Handle the response
                 print(response)
@@ -2322,11 +2322,11 @@ async def sample_delete_link():
                 )
 
                 # Make the request
-                operation = client.delete_link(request=request)
+                operation = await client.delete_link(request=request)
 
                 print("Waiting for operation to complete...")
 
-                response = (await operation).result()
+                response = await operation.result()
 
                 # Handle the response
                 print(response)
@@ -3840,11 +3840,11 @@ async def sample_copy_log_entries():
                 )
 
                 # Make the request
-                operation = client.copy_log_entries(request=request)
+                operation = await client.copy_log_entries(request=request)
 
                 print("Waiting for operation to complete...")
 
-                response = (await operation).result()
+                response = await operation.result()
 
                 # Handle the response
                 print(response)

tests/integration/goldens/logging/samples/generated_samples/logging_v2_generated_config_service_v2_copy_log_entries_async.py

@@ -45,11 +45,11 @@ async def sample_copy_log_entries():
     )
 
     # Make the request
-    operation = client.copy_log_entries(request=request)
+    operation = await client.copy_log_entries(request=request)
 
     print("Waiting for operation to complete...")
 
-    response = (await operation).result()
+    response = await operation.result()
 
     # Handle the response
     print(response)