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 ee1049a1f71c..8bd1b6d095bb 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 @@ -313,7 +313,7 @@ def test_write_with_beam_rows_cdc(self): | StorageWriteToBigQuery( table=table_id, create_disposition="CREATE_NEVER", - use_cdc_writes_with_primary_key=(primaryKeyColumns) + use_cdc_writes_with_primary_key=["name"] )) hamcrest_assert(p, bq_matcher)