This is an automated email from the ASF dual-hosted git repository.

damondouglas 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 924c6a29840 Add unique ID to Dataflow BOM tests (#30709)
924c6a29840 is described below

commit 924c6a29840d2692b315b4499f3eec17c465485f
Author: Damon <damondoug...@users.noreply.github.com>
AuthorDate: Thu Mar 21 16:12:06 2024 -0700

    Add unique ID to Dataflow BOM tests (#30709)
---
 release/src/main/groovy/mobilegaming-java-dataflowbom.groovy | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/release/src/main/groovy/mobilegaming-java-dataflowbom.groovy 
b/release/src/main/groovy/mobilegaming-java-dataflowbom.groovy
index 87944588e35..a0fd0f13c75 100644
--- a/release/src/main/groovy/mobilegaming-java-dataflowbom.groovy
+++ b/release/src/main/groovy/mobilegaming-java-dataflowbom.groovy
@@ -18,7 +18,6 @@
  */
 
 t = new TestScripts(args)
-mobileGamingCommands = new MobileGamingCommands(testScripts: t)
 
 /*
  * Run the mobile game examples on Dataflow.
@@ -36,6 +35,8 @@ String command_output_text
  *  Run the UserScore example on DataflowRunner
  * */
 
+mobileGamingCommands = new MobileGamingCommands(testScripts: t, testRunId: 
UUID.randomUUID().toString())
+
 t.intent("Running: UserScore example with Beam GCP BOM on DataflowRunner")
 t.run(mobileGamingCommands.createPipelineCommand("UserScore", runner))
 command_output_text = t.run "gsutil cat 
gs://${t.gcsBucket()}/${mobileGamingCommands.getUserScoreOutputName(runner)}* | 
grep user19_BananaWallaby"
@@ -48,6 +49,8 @@ t.run "gsutil rm 
gs://${t.gcsBucket()}/${mobileGamingCommands.getUserScoreOutput
  * Run the HourlyTeamScore example on DataflowRunner
  * */
 
+mobileGamingCommands = new MobileGamingCommands(testScripts: t, testRunId: 
UUID.randomUUID().toString())
+
 t.intent("Running: HourlyTeamScore example with Beam GCP BOM on 
DataflowRunner")
 t.run(mobileGamingCommands.createPipelineCommand("HourlyTeamScore", runner))
 command_output_text = t.run "gsutil cat 
gs://${t.gcsBucket()}/${mobileGamingCommands.getHourlyTeamScoreOutputName(runner)}*
 | grep AzureBilby "

Reply via email to