chore(python): use black==22.3.0 (#417)

gcf-owl-bot[bot] · web-flow · commit cfae70236166 · 2022-03-29T00:02:11.000Z
Source-Link: googleapis/synthtool@6fab84a Post-Processor: gcr.io/cloud-devrel-public-resources/owlbot-python:latest@sha256:7cffbc10910c3ab1b852c05114a08d374c195a81cdec1d4a67a1d129331d0bfe
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_read_create_read_session_async.py b/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_read_create_read_session_async.py
@@ -32,7 +32,9 @@ async def sample_create_read_session():
     client = bigquery_storage_v1.BigQueryReadAsyncClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1.CreateReadSessionRequest(parent="parent_value",)
+    request = bigquery_storage_v1.CreateReadSessionRequest(
+        parent="parent_value",
+    )
 
     # Make the request
     response = await client.create_read_session(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_read_create_read_session_sync.py b/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_read_create_read_session_sync.py
@@ -32,7 +32,9 @@ def sample_create_read_session():
     client = bigquery_storage_v1.BigQueryReadClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1.CreateReadSessionRequest(parent="parent_value",)
+    request = bigquery_storage_v1.CreateReadSessionRequest(
+        parent="parent_value",
+    )
 
     # Make the request
     response = client.create_read_session(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_read_read_rows_async.py b/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_read_read_rows_async.py
@@ -32,7 +32,9 @@ async def sample_read_rows():
     client = bigquery_storage_v1.BigQueryReadAsyncClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1.ReadRowsRequest(read_stream="read_stream_value",)
+    request = bigquery_storage_v1.ReadRowsRequest(
+        read_stream="read_stream_value",
+    )
 
     # Make the request
     stream = await client.read_rows(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_read_read_rows_sync.py b/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_read_read_rows_sync.py
@@ -32,7 +32,9 @@ def sample_read_rows():
     client = bigquery_storage_v1.BigQueryReadClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1.ReadRowsRequest(read_stream="read_stream_value",)
+    request = bigquery_storage_v1.ReadRowsRequest(
+        read_stream="read_stream_value",
+    )
 
     # Make the request
     stream = client.read_rows(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_read_split_read_stream_async.py b/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_read_split_read_stream_async.py
@@ -32,7 +32,9 @@ async def sample_split_read_stream():
     client = bigquery_storage_v1.BigQueryReadAsyncClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1.SplitReadStreamRequest(name="name_value",)
+    request = bigquery_storage_v1.SplitReadStreamRequest(
+        name="name_value",
+    )
 
     # Make the request
     response = await client.split_read_stream(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_read_split_read_stream_sync.py b/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_read_split_read_stream_sync.py
@@ -32,7 +32,9 @@ def sample_split_read_stream():
     client = bigquery_storage_v1.BigQueryReadClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1.SplitReadStreamRequest(name="name_value",)
+    request = bigquery_storage_v1.SplitReadStreamRequest(
+        name="name_value",
+    )
 
     # Make the request
     response = client.split_read_stream(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_append_rows_async.py b/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_append_rows_async.py
@@ -32,7 +32,9 @@ async def sample_append_rows():
     client = bigquery_storage_v1.BigQueryWriteAsyncClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1.AppendRowsRequest(write_stream="write_stream_value",)
+    request = bigquery_storage_v1.AppendRowsRequest(
+        write_stream="write_stream_value",
+    )
 
     # This method expects an iterator which contains
     # 'bigquery_storage_v1.AppendRowsRequest' objects
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_append_rows_sync.py b/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_append_rows_sync.py
@@ -32,7 +32,9 @@ def sample_append_rows():
     client = bigquery_storage_v1.BigQueryWriteClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1.AppendRowsRequest(write_stream="write_stream_value",)
+    request = bigquery_storage_v1.AppendRowsRequest(
+        write_stream="write_stream_value",
+    )
 
     # This method expects an iterator which contains
     # 'bigquery_storage_v1.AppendRowsRequest' objects
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_create_write_stream_async.py b/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_create_write_stream_async.py
@@ -32,7 +32,9 @@ async def sample_create_write_stream():
     client = bigquery_storage_v1.BigQueryWriteAsyncClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1.CreateWriteStreamRequest(parent="parent_value",)
+    request = bigquery_storage_v1.CreateWriteStreamRequest(
+        parent="parent_value",
+    )
 
     # Make the request
     response = await client.create_write_stream(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_create_write_stream_sync.py b/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_create_write_stream_sync.py
@@ -32,7 +32,9 @@ def sample_create_write_stream():
     client = bigquery_storage_v1.BigQueryWriteClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1.CreateWriteStreamRequest(parent="parent_value",)
+    request = bigquery_storage_v1.CreateWriteStreamRequest(
+        parent="parent_value",
+    )
 
     # Make the request
     response = client.create_write_stream(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_finalize_write_stream_async.py b/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_finalize_write_stream_async.py
@@ -32,7 +32,9 @@ async def sample_finalize_write_stream():
     client = bigquery_storage_v1.BigQueryWriteAsyncClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1.FinalizeWriteStreamRequest(name="name_value",)
+    request = bigquery_storage_v1.FinalizeWriteStreamRequest(
+        name="name_value",
+    )
 
     # Make the request
     response = await client.finalize_write_stream(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_finalize_write_stream_sync.py b/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_finalize_write_stream_sync.py
@@ -32,7 +32,9 @@ def sample_finalize_write_stream():
     client = bigquery_storage_v1.BigQueryWriteClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1.FinalizeWriteStreamRequest(name="name_value",)
+    request = bigquery_storage_v1.FinalizeWriteStreamRequest(
+        name="name_value",
+    )
 
     # Make the request
     response = client.finalize_write_stream(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_flush_rows_async.py b/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_flush_rows_async.py
@@ -32,7 +32,9 @@ async def sample_flush_rows():
     client = bigquery_storage_v1.BigQueryWriteAsyncClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1.FlushRowsRequest(write_stream="write_stream_value",)
+    request = bigquery_storage_v1.FlushRowsRequest(
+        write_stream="write_stream_value",
+    )
 
     # Make the request
     response = await client.flush_rows(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_flush_rows_sync.py b/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_flush_rows_sync.py
@@ -32,7 +32,9 @@ def sample_flush_rows():
     client = bigquery_storage_v1.BigQueryWriteClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1.FlushRowsRequest(write_stream="write_stream_value",)
+    request = bigquery_storage_v1.FlushRowsRequest(
+        write_stream="write_stream_value",
+    )
 
     # Make the request
     response = client.flush_rows(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_get_write_stream_async.py b/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_get_write_stream_async.py
@@ -32,7 +32,9 @@ async def sample_get_write_stream():
     client = bigquery_storage_v1.BigQueryWriteAsyncClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1.GetWriteStreamRequest(name="name_value",)
+    request = bigquery_storage_v1.GetWriteStreamRequest(
+        name="name_value",
+    )
 
     # Make the request
     response = await client.get_write_stream(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_get_write_stream_sync.py b/bigquery_storage/generated_samples/bigquerystorage_v1_generated_big_query_write_get_write_stream_sync.py
@@ -32,7 +32,9 @@ def sample_get_write_stream():
     client = bigquery_storage_v1.BigQueryWriteClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1.GetWriteStreamRequest(name="name_value",)
+    request = bigquery_storage_v1.GetWriteStreamRequest(
+        name="name_value",
+    )
 
     # Make the request
     response = client.get_write_stream(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_read_create_read_session_async.py b/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_read_create_read_session_async.py
@@ -32,7 +32,9 @@ async def sample_create_read_session():
     client = bigquery_storage_v1beta2.BigQueryReadAsyncClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1beta2.CreateReadSessionRequest(parent="parent_value",)
+    request = bigquery_storage_v1beta2.CreateReadSessionRequest(
+        parent="parent_value",
+    )
 
     # Make the request
     response = await client.create_read_session(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_read_create_read_session_sync.py b/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_read_create_read_session_sync.py
@@ -32,7 +32,9 @@ def sample_create_read_session():
     client = bigquery_storage_v1beta2.BigQueryReadClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1beta2.CreateReadSessionRequest(parent="parent_value",)
+    request = bigquery_storage_v1beta2.CreateReadSessionRequest(
+        parent="parent_value",
+    )
 
     # Make the request
     response = client.create_read_session(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_read_read_rows_async.py b/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_read_read_rows_async.py
@@ -32,7 +32,9 @@ async def sample_read_rows():
     client = bigquery_storage_v1beta2.BigQueryReadAsyncClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1beta2.ReadRowsRequest(read_stream="read_stream_value",)
+    request = bigquery_storage_v1beta2.ReadRowsRequest(
+        read_stream="read_stream_value",
+    )
 
     # Make the request
     stream = await client.read_rows(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_read_read_rows_sync.py b/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_read_read_rows_sync.py
@@ -32,7 +32,9 @@ def sample_read_rows():
     client = bigquery_storage_v1beta2.BigQueryReadClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1beta2.ReadRowsRequest(read_stream="read_stream_value",)
+    request = bigquery_storage_v1beta2.ReadRowsRequest(
+        read_stream="read_stream_value",
+    )
 
     # Make the request
     stream = client.read_rows(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_read_split_read_stream_async.py b/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_read_split_read_stream_async.py
@@ -32,7 +32,9 @@ async def sample_split_read_stream():
     client = bigquery_storage_v1beta2.BigQueryReadAsyncClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1beta2.SplitReadStreamRequest(name="name_value",)
+    request = bigquery_storage_v1beta2.SplitReadStreamRequest(
+        name="name_value",
+    )
 
     # Make the request
     response = await client.split_read_stream(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_read_split_read_stream_sync.py b/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_read_split_read_stream_sync.py
@@ -32,7 +32,9 @@ def sample_split_read_stream():
     client = bigquery_storage_v1beta2.BigQueryReadClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1beta2.SplitReadStreamRequest(name="name_value",)
+    request = bigquery_storage_v1beta2.SplitReadStreamRequest(
+        name="name_value",
+    )
 
     # Make the request
     response = client.split_read_stream(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_write_create_write_stream_async.py b/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_write_create_write_stream_async.py
@@ -32,7 +32,9 @@ async def sample_create_write_stream():
     client = bigquery_storage_v1beta2.BigQueryWriteAsyncClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1beta2.CreateWriteStreamRequest(parent="parent_value",)
+    request = bigquery_storage_v1beta2.CreateWriteStreamRequest(
+        parent="parent_value",
+    )
 
     # Make the request
     response = await client.create_write_stream(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_write_create_write_stream_sync.py b/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_write_create_write_stream_sync.py
@@ -32,7 +32,9 @@ def sample_create_write_stream():
     client = bigquery_storage_v1beta2.BigQueryWriteClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1beta2.CreateWriteStreamRequest(parent="parent_value",)
+    request = bigquery_storage_v1beta2.CreateWriteStreamRequest(
+        parent="parent_value",
+    )
 
     # Make the request
     response = client.create_write_stream(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_write_finalize_write_stream_async.py b/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_write_finalize_write_stream_async.py
@@ -32,7 +32,9 @@ async def sample_finalize_write_stream():
     client = bigquery_storage_v1beta2.BigQueryWriteAsyncClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1beta2.FinalizeWriteStreamRequest(name="name_value",)
+    request = bigquery_storage_v1beta2.FinalizeWriteStreamRequest(
+        name="name_value",
+    )
 
     # Make the request
     response = await client.finalize_write_stream(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_write_finalize_write_stream_sync.py b/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_write_finalize_write_stream_sync.py
@@ -32,7 +32,9 @@ def sample_finalize_write_stream():
     client = bigquery_storage_v1beta2.BigQueryWriteClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1beta2.FinalizeWriteStreamRequest(name="name_value",)
+    request = bigquery_storage_v1beta2.FinalizeWriteStreamRequest(
+        name="name_value",
+    )
 
     # Make the request
     response = client.finalize_write_stream(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_write_get_write_stream_async.py b/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_write_get_write_stream_async.py
@@ -32,7 +32,9 @@ async def sample_get_write_stream():
     client = bigquery_storage_v1beta2.BigQueryWriteAsyncClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1beta2.GetWriteStreamRequest(name="name_value",)
+    request = bigquery_storage_v1beta2.GetWriteStreamRequest(
+        name="name_value",
+    )
 
     # Make the request
     response = await client.get_write_stream(request=request)
diff --git a/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_write_get_write_stream_sync.py b/bigquery_storage/generated_samples/bigquerystorage_v1beta2_generated_big_query_write_get_write_stream_sync.py
@@ -32,7 +32,9 @@ def sample_get_write_stream():
     client = bigquery_storage_v1beta2.BigQueryWriteClient()
 
     # Initialize request argument(s)
-    request = bigquery_storage_v1beta2.GetWriteStreamRequest(name="name_value",)
+    request = bigquery_storage_v1beta2.GetWriteStreamRequest(
+        name="name_value",
+    )
 
     # Make the request
     response = client.get_write_stream(request=request)
diff --git a/bigquery_storage/quickstart/noxfile.py b/bigquery_storage/quickstart/noxfile.py
@@ -29,7 +29,7 @@
 # WARNING - WARNING - WARNING - WARNING - WARNING
 # WARNING - WARNING - WARNING - WARNING - WARNING
 
-BLACK_VERSION = "black==19.10b0"
+BLACK_VERSION = "black==22.3.0"
 
 # Copy `noxfile_config.py` to your directory and modify it instead.
 
@@ -253,7 +253,7 @@ def py(session: nox.sessions.Session) -> None:
 
 
 def _get_repo_root() -> Optional[str]:
-    """ Returns the root folder of the project. """
+    """Returns the root folder of the project."""
     # Get root of this repository. Assume we don't have directories nested deeper than 10 items.
     p = Path(os.getcwd())
     for i in range(10):
diff --git a/bigquery_storage/snippets/append_rows_proto2_test.py b/bigquery_storage/snippets/append_rows_proto2_test.py
@@ -116,7 +116,10 @@ def test_append_rows_proto2(
         ),
     ) in row_items
     assert (("int64_list", [1, 2, 3]), ("row_num", 13)) in row_items
-    assert (("row_num", 14), ("struct_col", {"sub_int_col": 7}),) in row_items
+    assert (
+        ("row_num", 14),
+        ("struct_col", {"sub_int_col": 7}),
+    ) in row_items
     assert (
         ("row_num", 15),
         (
diff --git a/bigquery_storage/snippets/noxfile.py b/bigquery_storage/snippets/noxfile.py
@@ -29,7 +29,7 @@
 # WARNING - WARNING - WARNING - WARNING - WARNING
 # WARNING - WARNING - WARNING - WARNING - WARNING
 
-BLACK_VERSION = "black==19.10b0"
+BLACK_VERSION = "black==22.3.0"
 
 # Copy `noxfile_config.py` to your directory and modify it instead.
 
@@ -253,7 +253,7 @@ def py(session: nox.sessions.Session) -> None:
 
 
 def _get_repo_root() -> Optional[str]:
-    """ Returns the root folder of the project. """
+    """Returns the root folder of the project."""
     # Get root of this repository. Assume we don't have directories nested deeper than 10 items.
     p = Path(os.getcwd())
     for i in range(10):
diff --git a/bigquery_storage/snippets/sample_data_pb2.py b/bigquery_storage/snippets/sample_data_pb2.py
diff --git a/bigquery_storage/to_dataframe/noxfile.py b/bigquery_storage/to_dataframe/noxfile.py
@@ -29,7 +29,7 @@
 # WARNING - WARNING - WARNING - WARNING - WARNING
 # WARNING - WARNING - WARNING - WARNING - WARNING
 
-BLACK_VERSION = "black==19.10b0"
+BLACK_VERSION = "black==22.3.0"
 
 # Copy `noxfile_config.py` to your directory and modify it instead.
 
@@ -253,7 +253,7 @@ def py(session: nox.sessions.Session) -> None:
 
 
 def _get_repo_root() -> Optional[str]:
-    """ Returns the root folder of the project. """
+    """Returns the root folder of the project."""
     # Get root of this repository. Assume we don't have directories nested deeper than 10 items.
     p = Path(os.getcwd())
     for i in range(10):
diff --git a/bigquery_storage/to_dataframe/read_table_bqstorage.py b/bigquery_storage/to_dataframe/read_table_bqstorage.py
@@ -49,7 +49,9 @@ def read_table(your_project_id):
         read_options=read_options,
     )
     read_session = bqstorageclient.create_read_session(
-        parent=parent, read_session=requested_session, max_stream_count=1,
+        parent=parent,
+        read_session=requested_session,
+        max_stream_count=1,
     )
 
     # This example reads from only a single stream. Read from multiple streams
