(beam) branch transform_service_test_suite updated: updates

[chamikara]

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 04d6cdcd08b updates
04d6cdcd08b is described below

commit 04d6cdcd08b238645532e7d25ec78d120efcb988
Author: Chamikara Jayalath <chamikar...@gmail.com>
AuthorDate: Thu Feb 15 13:00:28 2024 -0800

    updates
---
 sdks/python/apache_beam/io/external/xlang_bigqueryio_it_test.py | 1 +
 sdks/python/apache_beam/io/gcp/bigtableio_it_test.py            | 1 -
 sdks/python/scripts/run_transform_service.sh                    | 2 +-
 3 files changed, 2 insertions(+), 2 deletions(-)

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 c1e9754526e..5395a0a3678 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
@@ -53,6 +53,7 @@ _LOGGER = logging.getLogger(__name__)
 
 
 @pytest.mark.uses_gcp_java_expansion_service
+@pytest.mark.uses_transform_service
 class BigQueryXlangStorageWriteIT(unittest.TestCase):
   BIGQUERY_DATASET = 'python_xlang_storage_write'
 
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 867dca9a5e7..4b19a15e527 100644
--- a/sdks/python/apache_beam/io/gcp/bigtableio_it_test.py
+++ b/sdks/python/apache_beam/io/gcp/bigtableio_it_test.py
@@ -57,7 +57,6 @@ def instance_prefix(instance):
 
 
 @pytest.mark.uses_gcp_java_expansion_service
-@pytest.mark.uses_transform_service
 @unittest.skipUnless(
     os.environ.get('EXPANSION_PORT'),
     "EXPANSION_PORT environment var is not provided.")
diff --git a/sdks/python/scripts/run_transform_service.sh 
b/sdks/python/scripts/run_transform_service.sh
index a4f63bd6288..0d1fa5f1bee 100755
--- a/sdks/python/scripts/run_transform_service.sh
+++ b/sdks/python/scripts/run_transform_service.sh
@@ -86,7 +86,7 @@ case $STARTSTOP in
     echo "************ xyz123 in script run_transform_service.sh: starting the 
service"
     echo "Starting the transform service for project $GROUP_ID at port 
$EXTERNAL_PORT for Beam version $BEAM_VERSION_DOCKER transform service startup 
jar is $TRANSFORM_SERVICE_LAUNCHER_JAR"
     java -jar $TRANSFORM_SERVICE_LAUNCHER_JAR --project_name $GROUP_ID --port 
$EXTERNAL_PORT --beam_version $BEAM_VERSION_DOCKER --command up  
>$TEMP_DIR/$FILE_BASE-java1.log 2>&1 </dev/null
-    echo "************ xyz123 in script run_transform_service.sh: DONE the 
service"
+    echo "************ xyz123 in script run_transform_service.sh: DONE 
starting the service"
     ;;
   stop)
     echo "Stopping the transform service for project $GROUP_ID at port 
$EXTERNAL_PORT for Beam version $BEAM_VERSION_DOCKER  transform service startup 
jar is $TRANSFORM_SERVICE_LAUNCHER_JAR"