This is an automated email from the ASF dual-hosted git repository.
chamikara pushed a commit to branch transform_service_test_suite
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/transform_service_test_suite
by this push:
new 9fb47822258 updates
9fb47822258 is described below
commit 9fb47822258999ffc342ec591fc2b3cbdef688d0
Author: Chamikara Jayalath <[email protected]>
AuthorDate: Tue Mar 5 17:23:58 2024 -0800
updates
---
sdks/python/apache_beam/io/gcp/bigtableio_it_test.py | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/sdks/python/apache_beam/io/gcp/bigtableio_it_test.py
b/sdks/python/apache_beam/io/gcp/bigtableio_it_test.py
index b34e072e6d8..763f09d1f5c 100644
--- a/sdks/python/apache_beam/io/gcp/bigtableio_it_test.py
+++ b/sdks/python/apache_beam/io/gcp/bigtableio_it_test.py
@@ -197,6 +197,11 @@ class TestWriteToBigtableXlangIT(unittest.TestCase):
(self.TABLE_ID, str(int(time.time())), secrets.token_hex(3)))
self.table.create()
_LOGGER.info("Created table [%s]", self.table.table_id)
+ if (os.environ.get('TRANSFORM_SERVICE_PORT')):
+ self._transform_service_address = (
+ 'localhost:' + os.environ.get('TRANSFORM_SERVICE_PORT'))
+ else:
+ self._transform_service_address = None
def tearDown(self):
try:
