Skip to content

Commit 975d9fd

Browse files
gcf-owl-bot[bot]gcf-owl-bot[bot]
authored
chore: use gapic-generator-python 0.65.2 (#446)
* chore: use gapic-generator-python 0.65.2 PiperOrigin-RevId: 444333013 Source-Link: googleapis/googleapis@f91b6cf Source-Link: googleapis/googleapis-gen@16eb360 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMTZlYjM2MDk1YzI5NGU3MTJjNzRhMWJmMjM1NTA4MTdiNDIxNzRlNSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
1 parent 8eb55d8 commit 975d9fd

File tree

8 files changed

+122
-122
lines changed

8 files changed

+122
-122
lines changed

‎packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/services/big_query_read/async_client.py‎

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -256,17 +256,17 @@ async def create_read_session(
256256
257257
from google.cloud import bigquery_storage_v1
258258
259-
def sample_create_read_session():
259+
async def sample_create_read_session():
260260
# Create a client
261-
client = bigquery_storage_v1.BigQueryReadClient()
261+
client = bigquery_storage_v1.BigQueryReadAsyncClient()
262262
263263
# Initialize request argument(s)
264264
request = bigquery_storage_v1.CreateReadSessionRequest(
265265
parent="parent_value",
266266
)
267267
268268
# Make the request
269-
response = client.create_read_session(request=request)
269+
response = await client.create_read_session(request=request)
270270
271271
# Handle the response
272272
print(response)
@@ -397,20 +397,20 @@ def read_rows(
397397
398398
from google.cloud import bigquery_storage_v1
399399
400-
def sample_read_rows():
400+
async def sample_read_rows():
401401
# Create a client
402-
client = bigquery_storage_v1.BigQueryReadClient()
402+
client = bigquery_storage_v1.BigQueryReadAsyncClient()
403403
404404
# Initialize request argument(s)
405405
request = bigquery_storage_v1.ReadRowsRequest(
406406
read_stream="read_stream_value",
407407
)
408408
409409
# Make the request
410-
stream = client.read_rows(request=request)
410+
stream = await client.read_rows(request=request)
411411
412412
# Handle the response
413-
for response in stream:
413+
async for response in stream:
414414
print(response)
415415
416416
Args:
@@ -524,17 +524,17 @@ async def split_read_stream(
524524
525525
from google.cloud import bigquery_storage_v1
526526
527-
def sample_split_read_stream():
527+
async def sample_split_read_stream():
528528
# Create a client
529-
client = bigquery_storage_v1.BigQueryReadClient()
529+
client = bigquery_storage_v1.BigQueryReadAsyncClient()
530530
531531
# Initialize request argument(s)
532532
request = bigquery_storage_v1.SplitReadStreamRequest(
533533
name="name_value",
534534
)
535535
536536
# Make the request
537-
response = client.split_read_stream(request=request)
537+
response = await client.split_read_stream(request=request)
538538
539539
# Handle the response
540540
print(response)

‎packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/services/big_query_write/async_client.py‎

Lines changed: 19 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -244,17 +244,17 @@ async def create_write_stream(
244244
245245
from google.cloud import bigquery_storage_v1
246246
247-
def sample_create_write_stream():
247+
async def sample_create_write_stream():
248248
# Create a client
249-
client = bigquery_storage_v1.BigQueryWriteClient()
249+
client = bigquery_storage_v1.BigQueryWriteAsyncClient()
250250
251251
# Initialize request argument(s)
252252
request = bigquery_storage_v1.CreateWriteStreamRequest(
253253
parent="parent_value",
254254
)
255255
256256
# Make the request
257-
response = client.create_write_stream(request=request)
257+
response = await client.create_write_stream(request=request)
258258
259259
# Handle the response
260260
print(response)
@@ -397,9 +397,9 @@ def append_rows(
397397
398398
from google.cloud import bigquery_storage_v1
399399
400-
def sample_append_rows():
400+
async def sample_append_rows():
401401
# Create a client
402-
client = bigquery_storage_v1.BigQueryWriteClient()
402+
client = bigquery_storage_v1.BigQueryWriteAsyncClient()
403403
404404
# Initialize request argument(s)
405405
request = bigquery_storage_v1.AppendRowsRequest(
@@ -417,10 +417,10 @@ def request_generator():
417417
yield request
418418
419419
# Make the request
420-
stream = client.append_rows(requests=request_generator())
420+
stream = await client.append_rows(requests=request_generator())
421421
422422
# Handle the response
423-
for response in stream:
423+
async for response in stream:
424424
print(response)
425425
426426
Args:
@@ -488,17 +488,17 @@ async def get_write_stream(
488488
489489
from google.cloud import bigquery_storage_v1
490490
491-
def sample_get_write_stream():
491+
async def sample_get_write_stream():
492492
# Create a client
493-
client = bigquery_storage_v1.BigQueryWriteClient()
493+
client = bigquery_storage_v1.BigQueryWriteAsyncClient()
494494
495495
# Initialize request argument(s)
496496
request = bigquery_storage_v1.GetWriteStreamRequest(
497497
name="name_value",
498498
)
499499
500500
# Make the request
501-
response = client.get_write_stream(request=request)
501+
response = await client.get_write_stream(request=request)
502502
503503
# Handle the response
504504
print(response)
@@ -595,17 +595,17 @@ async def finalize_write_stream(
595595
596596
from google.cloud import bigquery_storage_v1
597597
598-
def sample_finalize_write_stream():
598+
async def sample_finalize_write_stream():
599599
# Create a client
600-
client = bigquery_storage_v1.BigQueryWriteClient()
600+
client = bigquery_storage_v1.BigQueryWriteAsyncClient()
601601
602602
# Initialize request argument(s)
603603
request = bigquery_storage_v1.FinalizeWriteStreamRequest(
604604
name="name_value",
605605
)
606606
607607
# Make the request
608-
response = client.finalize_write_stream(request=request)
608+
response = await client.finalize_write_stream(request=request)
609609
610610
# Handle the response
611611
print(response)
@@ -703,9 +703,9 @@ async def batch_commit_write_streams(
703703
704704
from google.cloud import bigquery_storage_v1
705705
706-
def sample_batch_commit_write_streams():
706+
async def sample_batch_commit_write_streams():
707707
# Create a client
708-
client = bigquery_storage_v1.BigQueryWriteClient()
708+
client = bigquery_storage_v1.BigQueryWriteAsyncClient()
709709
710710
# Initialize request argument(s)
711711
request = bigquery_storage_v1.BatchCommitWriteStreamsRequest(
@@ -714,7 +714,7 @@ def sample_batch_commit_write_streams():
714714
)
715715
716716
# Make the request
717-
response = client.batch_commit_write_streams(request=request)
717+
response = await client.batch_commit_write_streams(request=request)
718718
719719
# Handle the response
720720
print(response)
@@ -817,17 +817,17 @@ async def flush_rows(
817817
818818
from google.cloud import bigquery_storage_v1
819819
820-
def sample_flush_rows():
820+
async def sample_flush_rows():
821821
# Create a client
822-
client = bigquery_storage_v1.BigQueryWriteClient()
822+
client = bigquery_storage_v1.BigQueryWriteAsyncClient()
823823
824824
# Initialize request argument(s)
825825
request = bigquery_storage_v1.FlushRowsRequest(
826826
write_stream="write_stream_value",
827827
)
828828
829829
# Make the request
830-
response = client.flush_rows(request=request)
830+
response = await client.flush_rows(request=request)
831831
832832
# Handle the response
833833
print(response)

‎packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1beta2/services/big_query_read/async_client.py‎

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -258,17 +258,17 @@ async def create_read_session(
258258
259259
from google.cloud import bigquery_storage_v1beta2
260260
261-
def sample_create_read_session():
261+
async def sample_create_read_session():
262262
# Create a client
263-
client = bigquery_storage_v1beta2.BigQueryReadClient()
263+
client = bigquery_storage_v1beta2.BigQueryReadAsyncClient()
264264
265265
# Initialize request argument(s)
266266
request = bigquery_storage_v1beta2.CreateReadSessionRequest(
267267
parent="parent_value",
268268
)
269269
270270
# Make the request
271-
response = client.create_read_session(request=request)
271+
response = await client.create_read_session(request=request)
272272
273273
# Handle the response
274274
print(response)
@@ -399,20 +399,20 @@ def read_rows(
399399
400400
from google.cloud import bigquery_storage_v1beta2
401401
402-
def sample_read_rows():
402+
async def sample_read_rows():
403403
# Create a client
404-
client = bigquery_storage_v1beta2.BigQueryReadClient()
404+
client = bigquery_storage_v1beta2.BigQueryReadAsyncClient()
405405
406406
# Initialize request argument(s)
407407
request = bigquery_storage_v1beta2.ReadRowsRequest(
408408
read_stream="read_stream_value",
409409
)
410410
411411
# Make the request
412-
stream = client.read_rows(request=request)
412+
stream = await client.read_rows(request=request)
413413
414414
# Handle the response
415-
for response in stream:
415+
async for response in stream:
416416
print(response)
417417
418418
Args:
@@ -526,17 +526,17 @@ async def split_read_stream(
526526
527527
from google.cloud import bigquery_storage_v1beta2
528528
529-
def sample_split_read_stream():
529+
async def sample_split_read_stream():
530530
# Create a client
531-
client = bigquery_storage_v1beta2.BigQueryReadClient()
531+
client = bigquery_storage_v1beta2.BigQueryReadAsyncClient()
532532
533533
# Initialize request argument(s)
534534
request = bigquery_storage_v1beta2.SplitReadStreamRequest(
535535
name="name_value",
536536
)
537537
538538
# Make the request
539-
response = client.split_read_stream(request=request)
539+
response = await client.split_read_stream(request=request)
540540
541541
# Handle the response
542542
print(response)

‎packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1beta2/services/big_query_write/async_client.py‎

Lines changed: 19 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -242,17 +242,17 @@ async def create_write_stream(
242242
243243
from google.cloud import bigquery_storage_v1beta2
244244
245-
def sample_create_write_stream():
245+
async def sample_create_write_stream():
246246
# Create a client
247-
client = bigquery_storage_v1beta2.BigQueryWriteClient()
247+
client = bigquery_storage_v1beta2.BigQueryWriteAsyncClient()
248248
249249
# Initialize request argument(s)
250250
request = bigquery_storage_v1beta2.CreateWriteStreamRequest(
251251
parent="parent_value",
252252
)
253253
254254
# Make the request
255-
response = client.create_write_stream(request=request)
255+
response = await client.create_write_stream(request=request)
256256
257257
# Handle the response
258258
print(response)
@@ -376,9 +376,9 @@ def append_rows(
376376
377377
from google.cloud import bigquery_storage_v1beta2
378378
379-
def sample_append_rows():
379+
async def sample_append_rows():
380380
# Create a client
381-
client = bigquery_storage_v1beta2.BigQueryWriteClient()
381+
client = bigquery_storage_v1beta2.BigQueryWriteAsyncClient()
382382
383383
# Initialize request argument(s)
384384
request = bigquery_storage_v1beta2.AppendRowsRequest(
@@ -396,10 +396,10 @@ def request_generator():
396396
yield request
397397
398398
# Make the request
399-
stream = client.append_rows(requests=request_generator())
399+
stream = await client.append_rows(requests=request_generator())
400400
401401
# Handle the response
402-
for response in stream:
402+
async for response in stream:
403403
print(response)
404404
405405
Args:
@@ -464,17 +464,17 @@ async def get_write_stream(
464464
465465
from google.cloud import bigquery_storage_v1beta2
466466
467-
def sample_get_write_stream():
467+
async def sample_get_write_stream():
468468
# Create a client
469-
client = bigquery_storage_v1beta2.BigQueryWriteClient()
469+
client = bigquery_storage_v1beta2.BigQueryWriteAsyncClient()
470470
471471
# Initialize request argument(s)
472472
request = bigquery_storage_v1beta2.GetWriteStreamRequest(
473473
name="name_value",
474474
)
475475
476476
# Make the request
477-
response = client.get_write_stream(request=request)
477+
response = await client.get_write_stream(request=request)
478478
479479
# Handle the response
480480
print(response)
@@ -571,17 +571,17 @@ async def finalize_write_stream(
571571
572572
from google.cloud import bigquery_storage_v1beta2
573573
574-
def sample_finalize_write_stream():
574+
async def sample_finalize_write_stream():
575575
# Create a client
576-
client = bigquery_storage_v1beta2.BigQueryWriteClient()
576+
client = bigquery_storage_v1beta2.BigQueryWriteAsyncClient()
577577
578578
# Initialize request argument(s)
579579
request = bigquery_storage_v1beta2.FinalizeWriteStreamRequest(
580580
name="name_value",
581581
)
582582
583583
# Make the request
584-
response = client.finalize_write_stream(request=request)
584+
response = await client.finalize_write_stream(request=request)
585585
586586
# Handle the response
587587
print(response)
@@ -678,9 +678,9 @@ async def batch_commit_write_streams(
678678
679679
from google.cloud import bigquery_storage_v1beta2
680680
681-
def sample_batch_commit_write_streams():
681+
async def sample_batch_commit_write_streams():
682682
# Create a client
683-
client = bigquery_storage_v1beta2.BigQueryWriteClient()
683+
client = bigquery_storage_v1beta2.BigQueryWriteAsyncClient()
684684
685685
# Initialize request argument(s)
686686
request = bigquery_storage_v1beta2.BatchCommitWriteStreamsRequest(
@@ -689,7 +689,7 @@ def sample_batch_commit_write_streams():
689689
)
690690
691691
# Make the request
692-
response = client.batch_commit_write_streams(request=request)
692+
response = await client.batch_commit_write_streams(request=request)
693693
694694
# Handle the response
695695
print(response)
@@ -788,17 +788,17 @@ async def flush_rows(
788788
789789
from google.cloud import bigquery_storage_v1beta2
790790
791-
def sample_flush_rows():
791+
async def sample_flush_rows():
792792
# Create a client
793-
client = bigquery_storage_v1beta2.BigQueryWriteClient()
793+
client = bigquery_storage_v1beta2.BigQueryWriteAsyncClient()
794794
795795
# Initialize request argument(s)
796796
request = bigquery_storage_v1beta2.FlushRowsRequest(
797797
write_stream="write_stream_value",
798798
)
799799
800800
# Make the request
801-
response = client.flush_rows(request=request)
801+
response = await client.flush_rows(request=request)
802802
803803
# Handle the response
804804
print(response)

0 commit comments

Comments
 (0)