diff --git a/sdks/python/apache_beam/io/gcp/bigquery_read_it_test.py b/sdks/python/apache_beam/io/gcp/bigquery_read_it_test.py index 589bf79437cb..d56a4c764715 100644 --- a/sdks/python/apache_beam/io/gcp/bigquery_read_it_test.py +++ b/sdks/python/apache_beam/io/gcp/bigquery_read_it_test.py @@ -307,6 +307,7 @@ def test_table_schema_retrieve_with_direct_read(self): class ReadUsingStorageApiTests(BigQueryReadIntegrationTests): + BIG_QUERY_DATASET_ID = 'python_read_table_' TABLE_DATA = [{ 'number': 1, 'string': '你好', @@ -330,7 +331,8 @@ class ReadUsingStorageApiTests(BigQueryReadIntegrationTests): @classmethod def setUpClass(cls): super(ReadUsingStorageApiTests, cls).setUpClass() - cls.table_name = 'python_read_table' + cls.table_name = '%s%d%s' % ( + cls.BIG_QUERY_DATASET_ID, int(time.time()), secrets.token_hex(3)) cls._create_table(cls.table_name) table_id = '{}.{}'.format(cls.dataset_id, cls.table_name)