Skip to content

Commit

Permalink
updates
Browse files Browse the repository at this point in the history
  • Loading branch information
chamikaramj committed Feb 15, 2024
1 parent 04d6cdc commit ebb0986
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 1 deletion.
1 change: 0 additions & 1 deletion sdks/python/apache_beam/io/gcp/bigtableio_it_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -148,7 +148,6 @@ def test_read_xlang(self):


@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.")
Expand Down
4 changes: 4 additions & 0 deletions sdks/python/scripts/run_transform_service.sh
Original file line number Diff line number Diff line change
Expand Up @@ -87,6 +87,10 @@ case $STARTSTOP in
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 starting the service"
echo "************ xyz123 run_transform_service.sh: 4.1"
temp_output=`docker ps`
printf "Output from 'docker ps':\n${temp_output}\n\n"
echo "************ xyz123 run_transform_service.sh: 4.2"
;;
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"
Expand Down

0 comments on commit ebb0986

Please sign in to comment.