diff --git a/sdks/python/apache_beam/io/external/xlang_bigqueryio_it_test.py b/sdks/python/apache_beam/io/external/xlang_bigqueryio_it_test.py index b422b4312924..b508fa089747 100644 --- a/sdks/python/apache_beam/io/external/xlang_bigqueryio_it_test.py +++ b/sdks/python/apache_beam/io/external/xlang_bigqueryio_it_test.py @@ -303,8 +303,7 @@ def test_write_with_beam_rows_cdc(self): | StorageWriteToBigQuery( table=table_id, create_disposition="CREATE_NEVER", - use_cdc_writes_with_primary_key=["name"] - )) + use_cdc_writes_with_primary_key=["name"])) hamcrest_assert(p, bq_matcher) def test_write_to_dynamic_destinations(self):