This is an automated email from the ASF dual-hosted git repository.
damccorm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new d560aa63d58 make the table name unique in ReadUsingStorageApiTests
(#31552)
d560aa63d58 is described below
commit d560aa63d58145546def09aba7db6f0c8f39dbe0
Author: liferoad <[email protected]>
AuthorDate: Mon Jun 10 14:43:10 2024 -0400
make the table name unique in ReadUsingStorageApiTests (#31552)
---
sdks/python/apache_beam/io/gcp/bigquery_read_it_test.py | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
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 589bf79437c..d56a4c76471 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 @@ class ReadTests(BigQueryReadIntegrationTests):
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)