commit e09e02987c3a0a0aa8fce18a3cad519a212563ed
author Dennis Dmitriev <ddmitriev@mirantis.com> Tue Jul 30 16:39:27 2019 +0300
committer Dennis Dmitriev <ddmitriev@mirantis.com> Tue Jul 30 17:13:06 2019 +0300
tree c7c4e694c24460debd79c47409642aae719da75a
parent 1b12803b5f0e2290b810f1b3dcb2f0ceec55751e

Allow override 'propagate' in Workflow.groovy

Change-Id: I02147f580c5fa8b4302a5bc052e10e833b9b11ef
Related-task: https://mirantis.jira.com/browse/PROD-31616

src/com/mirantis/mk/Workflow.groovy

diff --git a/src/com/mirantis/mk/Workflow.groovy b/src/com/mirantis/mk/Workflow.groovy
index 092ede9..e798a19 100644
--- a/src/com/mirantis/mk/Workflow.groovy
+++ b/src/com/mirantis/mk/Workflow.groovy
@@ -25,8 +25,11 @@
  *                          {'PARAM_NAME': {'type': <job parameter $class name>, 'use_variable': <a key from global_variables>}, ...}
  * @param global_variables  Map that keeps the artifact URLs and used 'env' objects:
  *                          {'PARAM1_NAME': <param1 value>, 'PARAM2_NAME': 'http://.../artifacts/param2_value', ...}
+ * @param propagate         Boolean. If false: allows to collect artifacts after job is finished, even with FAILURE status
+ *                          If true: immediatelly fails the pipeline. DO NOT USE 'true' if you want to collect artifacts
+ *                          for 'finally' steps
  */
-def runJob(job_name, job_parameters, global_variables) {
+def runJob(job_name, job_parameters, global_variables, Boolean propagate = false) {
     def parameters = []
 
     // Collect required parameters from 'global_variables' or 'env'
@@ -39,7 +42,7 @@
     }
 
     // Build the job
-    def job_info = build job: "${job_name}", parameters: parameters, propagate: false
+    def job_info = build job: "${job_name}", parameters: parameters, propagate: propagate
     return job_info
 }
 
@@ -87,8 +90,10 @@
  * @param steps                   List of steps (Jenkins jobs) to execute
  * @param global_variables        Map where the collected artifact URLs and 'env' objects are stored
  * @param failed_jobs             Map with failed job names and result statuses, to report it later
+ * @param propagate               Boolean. If false: allows to collect artifacts after job is finished, even with FAILURE status
+ *                                If true: immediatelly fails the pipeline. DO NOT USE 'true' with runScenario().
  */
-def runSteps(steps, global_variables, failed_jobs) {
+def runSteps(steps, global_variables, failed_jobs, Boolean propagate = false) {
     currentBuild.description = ''
     for (step in steps) {
         stage("Running job ${step['job']}") {
@@ -96,7 +101,7 @@
             def job_name = step['job']
             def job_parameters = step['parameters']
             // Collect job parameters and run the job
-            def job_info = runJob(job_name, job_parameters, global_variables)
+            def job_info = runJob(job_name, job_parameters, global_variables, propagate)
             def job_result = job_info.getResult()
             def build_url = job_info.getAbsoluteUrl()
             def build_description = job_info.getDescription()