diff --git a/sdks/python/apache_beam/io/gcp/bigquery.py b/sdks/python/apache_beam/io/gcp/bigquery.py index a7849ad2e424..71cb1808492a 100644 --- a/sdks/python/apache_beam/io/gcp/bigquery.py +++ b/sdks/python/apache_beam/io/gcp/bigquery.py @@ -1921,7 +1921,7 @@ def __init__( load_job_project_id=None, max_insert_payload_size=MAX_INSERT_PAYLOAD_SIZE, num_streaming_keys=DEFAULT_SHARDS_PER_DESTINATION, - cdc_writes_with_primary_key:List[str]=None, + cdc_writes_with_primary_key: List[str] = None, expansion_service=None): """Initialize a WriteToBigQuery transform. @@ -2531,7 +2531,7 @@ def __init__( use_at_least_once=False, with_auto_sharding=False, num_storage_api_streams=0, - cdc_writes_with_primary_key:List[str]=None, + cdc_writes_with_primary_key: List[str] = None, expansion_service=None): self._table = table self._table_side_inputs = table_side_inputs