You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ki...@apache.org on 2022/02/07 20:04:37 UTC

[beam] branch master updated: [BEAM-12572] Change jobs to run as cron jobs

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

kileysok 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 3f75777  [BEAM-12572] Change jobs to run as cron jobs
     new 93ef2f5  Merge pull request #16746 from benWize/BEAM-12572-cron-jobs
3f75777 is described below

commit 3f75777c7d5153ecc54d103fbe1e8dbd6227826a
Author: Benjamin Gonzalez <be...@wizeline.com>
AuthorDate: Fri Feb 4 15:47:36 2022 -0600

    [BEAM-12572] Change jobs to run as cron jobs
---
 .../job_PostCommit_Python_Examples_Dataflow.groovy | 37 ++++++++---------
 .../job_PostCommit_Python_Examples_Direct.groovy   | 39 +++++++++---------
 .../job_PostCommit_Python_Examples_Flink.groovy    | 39 +++++++++---------
 .../job_PostCommit_Python_Examples_Spark.groovy    | 46 +++++++++++-----------
 4 files changed, 75 insertions(+), 86 deletions(-)

diff --git a/.test-infra/jenkins/job_PostCommit_Python_Examples_Dataflow.groovy b/.test-infra/jenkins/job_PostCommit_Python_Examples_Dataflow.groovy
index 89a9e92..4024025 100644
--- a/.test-infra/jenkins/job_PostCommit_Python_Examples_Dataflow.groovy
+++ b/.test-infra/jenkins/job_PostCommit_Python_Examples_Dataflow.groovy
@@ -17,30 +17,27 @@
  */
 
 import CommonJobProperties as commonJobProperties
+import PostcommitJobBuilder
 
 // This job runs the Python examples tests with DataflowRunner.
-job('beam_PostCommit_Python_Examples_Dataflow') {
-  description('Runs the Python Examples with DataflowRunner.')
+PostcommitJobBuilder.postCommitJob('beam_PostCommit_Python_Examples_Dataflow',
+    'Run Python Examples_Dataflow', 'Python Dataflow Runner Examples', this) {
 
-  // Set common parameters.
-  commonJobProperties.setTopLevelMainJobProperties(delegate, 'master', 120)
+      description('Runs the Python Examples with DataflowRunner')
 
-  // Allows triggering this build against pull requests.
-  commonJobProperties.enablePhraseTriggeringFromPullRequest(
-      delegate,
-      'Python Dataflow Runner Examples',
-      'Run Python Examples_Dataflow')
+      commonJobProperties.setTopLevelMainJobProperties(delegate, 'master', 120)
 
-  publishers {
-    archiveJunit('**/pytest*.xml')
-  }
+      // Publish all test results to Jenkins
+      publishers {
+        archiveJunit('**/pytest*.xml')
+      }
 
-  // Execute shell command to run examples.
-  steps {
-    gradle {
-      rootBuildScriptDir(commonJobProperties.checkoutDir)
-      tasks(":sdks:python:test-suites:dataflow:examplesPostCommit")
-      commonJobProperties.setGradleSwitches(delegate)
+      // Execute shell command to run examples.
+      steps {
+        gradle {
+          rootBuildScriptDir(commonJobProperties.checkoutDir)
+          tasks(":sdks:python:test-suites:dataflow:examplesPostCommit")
+          commonJobProperties.setGradleSwitches(delegate)
+        }
+      }
     }
-  }
-}
\ No newline at end of file
diff --git a/.test-infra/jenkins/job_PostCommit_Python_Examples_Direct.groovy b/.test-infra/jenkins/job_PostCommit_Python_Examples_Direct.groovy
index 6b3edbe..e420b04 100644
--- a/.test-infra/jenkins/job_PostCommit_Python_Examples_Direct.groovy
+++ b/.test-infra/jenkins/job_PostCommit_Python_Examples_Direct.groovy
@@ -17,30 +17,27 @@
  */
 
 import CommonJobProperties as commonJobProperties
+import PostcommitJobBuilder
 
 // This job runs the Python examples tests with DirectRunner.
-job('beam_PostCommit_Python_Examples_Direct') {
-  description('Runs the Python Examples with DirectRunner.')
+PostcommitJobBuilder.postCommitJob('beam_PostCommit_Python_Examples_Direct',
+    'Run Python Examples_Direct', 'Python Direct Runner Examples', this) {
 
-  // Set common parameters.
-  commonJobProperties.setTopLevelMainJobProperties(delegate, 'master', 120)
+      description('Runs the Python Examples with DirectRunner')
 
-  // Allows triggering this build against pull requests.
-  commonJobProperties.enablePhraseTriggeringFromPullRequest(
-      delegate,
-      'Python Direct Runner Examples',
-      'Run Python Examples_Direct')
+      commonJobProperties.setTopLevelMainJobProperties(delegate, 'master', 120)
 
-  publishers {
-    archiveJunit('**/pytest*.xml')
-  }
+      // Publish all test results to Jenkins
+      publishers {
+        archiveJunit('**/pytest*.xml')
+      }
 
-  // Execute shell command to run examples.
-  steps {
-    gradle {
-      rootBuildScriptDir(commonJobProperties.checkoutDir)
-      tasks(":sdks:python:test-suites:direct:examplesPostCommit")
-      commonJobProperties.setGradleSwitches(delegate)
-    }
-  }
-}
\ No newline at end of file
+      // Execute shell command to run examples.
+      steps {
+        gradle {
+          rootBuildScriptDir(commonJobProperties.checkoutDir)
+          tasks(":sdks:python:test-suites:direct:examplesPostCommit")
+          commonJobProperties.setGradleSwitches(delegate)
+        }
+      }
+    }
\ No newline at end of file
diff --git a/.test-infra/jenkins/job_PostCommit_Python_Examples_Flink.groovy b/.test-infra/jenkins/job_PostCommit_Python_Examples_Flink.groovy
index a86f286..779395b 100644
--- a/.test-infra/jenkins/job_PostCommit_Python_Examples_Flink.groovy
+++ b/.test-infra/jenkins/job_PostCommit_Python_Examples_Flink.groovy
@@ -17,30 +17,27 @@
  */
 
 import CommonJobProperties as commonJobProperties
+import PostcommitJobBuilder
 
 // This job runs the Python examples tests with FlinkRunner.
-job('beam_PostCommit_Python_Examples_Flink') {
-  description('Runs the Python Examples with Flink Runner.')
+PostcommitJobBuilder.postCommitJob('beam_PostCommit_Python_Examples_Flink',
+    'Run Python Examples_Flink', 'Python Flink Runner Examples', this) {
 
-  // Set common parameters.
-  commonJobProperties.setTopLevelMainJobProperties(delegate, 'master', 120)
+      description('Runs the Python Examples with Flink Runner')
 
-  // Allows triggering this build against pull requests.
-  commonJobProperties.enablePhraseTriggeringFromPullRequest(
-      delegate,
-      'Python Flink Runner Examples',
-      'Run Python Examples_Flink')
+      commonJobProperties.setTopLevelMainJobProperties(delegate, 'master', 120)
 
-  publishers {
-    archiveJunit('**/pytest*.xml')
-  }
+      // Publish all test results to Jenkins
+      publishers {
+        archiveJunit('**/pytest*.xml')
+      }
 
-  // Execute shell command to run examples.
-  steps {
-    gradle {
-      rootBuildScriptDir(commonJobProperties.checkoutDir)
-      tasks(":sdks:python:test-suites:portable:flinkExamplesPostCommit")
-      commonJobProperties.setGradleSwitches(delegate)
-    }
-  }
-}
\ No newline at end of file
+      // Execute shell command to run examples.
+      steps {
+        gradle {
+          rootBuildScriptDir(commonJobProperties.checkoutDir)
+          tasks(":sdks:python:test-suites:portable:flinkExamplesPostCommit")
+          commonJobProperties.setGradleSwitches(delegate)
+        }
+      }
+    }
\ No newline at end of file
diff --git a/.test-infra/jenkins/job_PostCommit_Python_Examples_Spark.groovy b/.test-infra/jenkins/job_PostCommit_Python_Examples_Spark.groovy
index dc8b00e..6277106 100644
--- a/.test-infra/jenkins/job_PostCommit_Python_Examples_Spark.groovy
+++ b/.test-infra/jenkins/job_PostCommit_Python_Examples_Spark.groovy
@@ -20,28 +20,26 @@ import CommonJobProperties as commonJobProperties
 import PostcommitJobBuilder
 
 // This job runs the Python examples tests with SparkRunner.
-job('beam_PostCommit_Python_Examples_Spark') {
-  description('Runs the Python Examples with Spark Runner.')
-
-  // Set common parameters.
-  commonJobProperties.setTopLevelMainJobProperties(delegate, 'master', 120)
-
-  // Allows triggering this build against pull requests.
-  commonJobProperties.enablePhraseTriggeringFromPullRequest(
-      delegate,
-      'Python Spark Runner Examples',
-      'Run Python Examples_Spark')
-
-  publishers {
-    archiveJunit('**/pytest*.xml')
-  }
-
-  // Execute shell command to run examples.
-  steps {
-    gradle {
-      rootBuildScriptDir(commonJobProperties.checkoutDir)
-      tasks(":sdks:python:test-suites:portable:sparkExamplesPostCommit")
-      commonJobProperties.setGradleSwitches(delegate)
+PostcommitJobBuilder.postCommitJob('beam_PostCommit_Python_Examples_Spark',
+    'Run Python Examples_Spark', 'Python Spark Runner Examples', this) {
+
+      description('Runs the Python Examples with Spark Runner')
+
+      commonJobProperties.setTopLevelMainJobProperties(delegate, 'master', 120)
+
+      // Publish all test results to Jenkins
+      publishers {
+        archiveJunit('**/pytest*.xml')
+      }
+
+      // Execute shell command to run examples.
+      steps {
+        gradle {
+          rootBuildScriptDir(commonJobProperties.checkoutDir)
+          tasks(":sdks:python:test-suites:portable:sparkExamplesPostCommit")
+          commonJobProperties.setGradleSwitches(delegate)
+        }
+      }
     }
-  }
-}
\ No newline at end of file
+
+