Update run_rc_validation_java_mobile_gaming.yml (#34466)

* Update run_rc_validation_java_mobile_gaming.yml

* Update run_rc_validation_java_mobile_gaming.yml

* Update run_rc_validation_java_mobile_gaming.yml

* Update run_rc_validation_java_mobile_gaming.yml

* Update run_rc_validation_java_mobile_gaming.yml

Author: liferoad

.github/workflows/run_rc_validation_java_mobile_gaming.yml

@@ -31,14 +31,6 @@ on:
       APACHE_CONTENTS_REPO:
         description: 'Apache Staging Repository URL (e.g., https://repository.apache.org/content/repositories/orgapachebeam-1234)'
         required: true
-      GCP_PROJECT_ID:
-        description: 'GCP Project ID for running the test'
-        required: true
-        default: 'apache-beam-testing' # Default project used in other validations
-      GCS_BUCKET:
-        description: 'GCS Bucket for temporary files (e.g., gs://rc-validation-migration-tests)'
-        required: true
-        default: 'gs://rc-validation-migration-tests'
 
 # This allows a subsequently queued workflow run to interrupt previous runs
 concurrency:
@@ -67,21 +59,24 @@ env:
   GRADLE_ENTERPRISE_CACHE_PASSWORD: ${{ secrets.GE_CACHE_PASSWORD }}
   # Define unique names for resources based on run ID to avoid collisions
   RUN_ID_SUFFIX: ${{ github.run_id }}_${{ github.run_attempt }}
-  BQ_DATASET: mobilegaming_java_rc_${{ env.RUN_ID_SUFFIX }}
-  PUBSUB_TOPIC: mobilegaming_java_rc_${{ env.RUN_ID_SUFFIX }}
-  # Use inputs for GCP details
-  GCP_PROJECT_ID: ${{ github.event.inputs.GCP_PROJECT_ID }}
-  GCS_BUCKET_NAME: ${{ github.event.inputs.GCS_BUCKET }} # Extract bucket name if gs:// prefix is included
+  BQ_DATASET: mobilegaming_java_rc_${{ github.run_id }}_${{ github.run_attempt }}
+  PUBSUB_TOPIC: mobilegaming_java_rc_${{ github.run_id }}_${{ github.run_attempt }}
+  # Set GCP Project ID and Bucket as constants
+  GCP_PROJECT_ID: 'apache-beam-testing'
+  GCS_BUCKET_NAME: 'gs://rc-validation-migration-tests'
   APACHE_REPO_URL: ${{ github.event.inputs.APACHE_CONTENTS_REPO }}
   RELEASE_VERSION: ${{ github.event.inputs.RELEASE_VER }}
   RC_TAG: "v${{github.event.inputs.RELEASE_VER}}-RC${{github.event.inputs.RC_NUM}}"
 
 jobs:
   run_java_mobile_gaming_rc_validation:
-    name: Run Java Mobile Gaming RC Validation (${{ env.RELEASE_VERSION }} RC${{ github.event.inputs.RC_NUM }})
+    name: Run Java Mobile Gaming RC Validation (${{ github.event.inputs.RELEASE_VER }} RC${{ github.event.inputs.RC_NUM }})
     runs-on: [self-hosted, ubuntu-20.04, main]
     timeout-minutes: 120 # Adjust timeout as needed
     steps:
+      - name: Extract GCS Bucket Name
+        run: echo "GCS_BUCKET_NAME=$(echo ${{ github.event.inputs.GCS_BUCKET }} | sed 's/^gs:\/\///')" >> $GITHUB_ENV
+      
       - name: Checkout code at RC tag
         uses: actions/checkout@v4
         with:
@@ -104,20 +99,19 @@ jobs:
           echo "Creating PubSub topic: ${{ env.PUBSUB_TOPIC }} in project ${{ env.GCP_PROJECT_ID }}"
           gcloud pubsub topics create --project=${{ env.GCP_PROJECT_ID }} ${{ env.PUBSUB_TOPIC }}
         shell: bash
-
+  
       # Run the Mobile Gaming example test using Gradle
       - name: Run MobileGaming Java Dataflow Test
         uses: ./.github/actions/gradle-command-self-hosted-action
         with:
-          gradle-command: >
-            :runners:google-cloud-dataflow-java:runMobileGamingJavaDataflow
-            -Prepourl=${{ env.APACHE_REPO_URL }}
-            -Pver=${{ env.RELEASE_VERSION }}
-            -PgcpProject=${{ env.GCP_PROJECT_ID }}
-            -PgcsBucket=${{ env.GCS_BUCKET_NAME }}
-            -PbqDataset=${{ env.BQ_DATASET }}
-            -PpubsubTopic=${{ env.PUBSUB_TOPIC }}
-          max-workers: 12 # Adjust as needed
+          gradle-command: :runners:google-cloud-dataflow-java:runMobileGamingJavaDataflow
+          arguments: |
+            -Prepourl=${{ env.APACHE_REPO_URL }} \
+            -Pver=${{ env.RELEASE_VERSION }} \
+            -PgcpProject=${{ env.GCP_PROJECT_ID }} \
+            -PgcsBucket=${{ env.GCS_BUCKET_NAME }} \
+            -PbqDataset=${{ env.BQ_DATASET }} \
+            -PpubsubTopic=${{ env.PUBSUB_TOPIC }} \
 
       # Cleanup GCP resources (always run)
       - name: Cleanup BigQuery Dataset