Bigquery Storage: Add empty lines, remove coverage exclusions (via synth).

bigquery_storage/google/cloud/bigquery_storage.py

@@ -14,10 +14,12 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
+
 from __future__ import absolute_import
 
 from google.cloud.bigquery_storage_v1beta1 import BigQueryStorageClient
 from google.cloud.bigquery_storage_v1beta1 import enums
 from google.cloud.bigquery_storage_v1beta1 import types
 
+
 __all__ = ("enums", "types", "BigQueryStorageClient")

bigquery_storage/google/cloud/bigquery_storage_v1beta1/gapic/big_query_storage_client.py

@@ -13,6 +13,7 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
+
 """Accesses the google.cloud.bigquery.storage.v1beta1 BigQueryStorage API."""
 
 import pkg_resources
@@ -38,6 +39,7 @@
 from google.cloud.bigquery_storage_v1beta1.proto import table_reference_pb2
 from google.protobuf import empty_pb2
 
+
 _GAPIC_LIBRARY_VERSION = pkg_resources.get_distribution(
  "google-cloud-bigquery-storage"
 ).version
@@ -288,7 +290,7 @@ def create_read_session(
  except AttributeError:
  pass
  else:
- routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata( # pragma: no cover
+ routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
  routing_header
  )
  metadata.append(routing_metadata) # pragma: no cover
@@ -373,7 +375,7 @@ def read_rows(
  except AttributeError:
  pass
  else:
- routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata( # pragma: no cover
+ routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
  routing_header
  )
  metadata.append(routing_metadata) # pragma: no cover
@@ -462,7 +464,7 @@ def batch_create_read_session_streams(
  except AttributeError:
  pass
  else:
- routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata( # pragma: no cover
+ routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
  routing_header
  )
  metadata.append(routing_metadata) # pragma: no cover
@@ -545,7 +547,7 @@ def finalize_stream(
  except AttributeError:
  pass
  else:
- routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata( # pragma: no cover
+ routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
  routing_header
  )
  metadata.append(routing_metadata) # pragma: no cover
@@ -630,7 +632,7 @@ def split_read_stream(
  except AttributeError:
  pass
  else:
- routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata( # pragma: no cover
+ routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
  routing_header
  )
  metadata.append(routing_metadata) # pragma: no cover

bigquery_storage/google/cloud/bigquery_storage_v1beta1/gapic/enums.py

@@ -13,6 +13,7 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
+
 """Wrappers for protocol buffer enum types."""
 
 import enum

bigquery_storage/google/cloud/bigquery_storage_v1beta1/gapic/transports/big_query_storage_grpc_transport.py

@@ -14,6 +14,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
+
 import google.api_core.grpc_helpers
 
 from google.cloud.bigquery_storage_v1beta1.proto import storage_pb2_grpc

bigquery_storage/google/cloud/bigquery_storage_v1beta1/types.py

@@ -14,6 +14,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
+
 from __future__ import absolute_import
 import sys
 
@@ -26,6 +27,7 @@
 from google.protobuf import empty_pb2
 from google.protobuf import timestamp_pb2
 
+
 _shared_modules = [empty_pb2, timestamp_pb2]
 
 _local_modules = [avro_pb2, read_options_pb2, storage_pb2, table_reference_pb2]
@@ -42,4 +44,5 @@
  setattr(sys.modules[__name__], name, message)
  names.append(name)
 
+
 __all__ = tuple(sorted(names))

bigquery_storage/synth.metadata

@@ -1,19 +1,19 @@
 {
- "updateTime": "2019-05-18T12:14:20.373269Z",
+ "updateTime": "2019-05-21T12:14:08.073652Z",
  "sources": [
  {
  "generator": {
  "name": "artman",
- "version": "0.19.0",
- "dockerImage": "googleapis/artman@sha256:d3df563538225ac6caac45d8ad86499500211d1bcb2536955a6dbda15e1b368e"
+ "version": "0.20.0",
+ "dockerImage": "googleapis/artman@sha256:3246adac900f4bdbd62920e80de2e5877380e44036b3feae13667ec255ebf5ec"
  }
  },
  {
  "git": {
  "name": "googleapis",
  "remote": "https://github.com/googleapis/googleapis.git",
- "sha": "64f0053af0c24d817ec44278c8b4513f6cfd77ff",
- "internalRef": "248810317"
+ "sha": "32a10f69e2c9ce15bba13ab1ff928bacebb25160",
+ "internalRef": "249058354"
  }
  }
  ],

bigquery_storage/tests/unit/gapic/v1beta1/test_big_query_storage_client_v1beta1.py

@@ -13,6 +13,7 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
+
 """Unit tests."""
 
 import mock