Skip to content

Commit 3d7b5b8

Browse files
committed
style: fix yapf formatting and add issue link to CHANGES.md
1 parent deee948 commit 3d7b5b8

2 files changed

Lines changed: 5 additions & 9 deletions

File tree

CHANGES.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@
6565

6666
## I/Os
6767

68-
* Added DATE, DATETIME, and JSON type support to BigQuery I/O for use with Storage Write API and BEAM_ROW format (Python).
68+
* Added DATE, DATETIME, and JSON type support to BigQuery I/O for use with Storage Write API and BEAM_ROW format (Python) ([#25946](https://github.com/apache/beam/issues/25946)).
6969

7070
# [2.71.0] - Unreleased
7171

sdks/python/apache_beam/io/gcp/bigquery_schema_tools_test.py

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -341,8 +341,7 @@ def test_date_type_support(self):
341341
fields = [
342342
bigquery.TableFieldSchema(
343343
name='birth_date', type='DATE', mode="NULLABLE"),
344-
bigquery.TableFieldSchema(
345-
name='dates', type='DATE', mode="REPEATED"),
344+
bigquery.TableFieldSchema(name='dates', type='DATE', mode="REPEATED"),
346345
bigquery.TableFieldSchema(
347346
name='required_date', type='DATE', mode="REQUIRED")
348347
]
@@ -537,10 +536,8 @@ def test_beam_schema_conversion_dofn_with_datetime(self):
537536
def test_json_type_support(self):
538537
"""Test that JSON type is properly supported in schema conversion."""
539538
fields = [
540-
bigquery.TableFieldSchema(
541-
name='data', type='JSON', mode="NULLABLE"),
542-
bigquery.TableFieldSchema(
543-
name='items', type='JSON', mode="REPEATED"),
539+
bigquery.TableFieldSchema(name='data', type='JSON', mode="NULLABLE"),
540+
bigquery.TableFieldSchema(name='items', type='JSON', mode="REPEATED"),
544541
bigquery.TableFieldSchema(
545542
name='required_data', type='JSON', mode="REQUIRED")
546543
]
@@ -614,8 +611,7 @@ def test_beam_schema_conversion_dofn_with_json(self):
614611
# Create a user type with JSON field
615612
fields = [
616613
bigquery.TableFieldSchema(name='id', type='INTEGER', mode="REQUIRED"),
617-
bigquery.TableFieldSchema(
618-
name='data', type='JSON', mode="NULLABLE")
614+
bigquery.TableFieldSchema(name='data', type='JSON', mode="NULLABLE")
619615
]
620616
schema = bigquery.TableSchema(fields=fields)
621617
usertype = bigquery_schema_tools.generate_user_type_from_bq_schema(schema)

0 commit comments

Comments
 (0)