fix(dryrun): remove pipeline config it for dry runs

spinnaker · Oct 19, 2017 · 45ddb81 · 45ddb81
1 parent e2990b8
commit 45ddb81
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/orca-dry-run/src/main/kotlin/com/netflix/spinnaker/config/DryRunConfiguration.kt b/orca-dry-run/src/main/kotlin/com/netflix/spinnaker/config/DryRunConfiguration.kt
@@ -17,11 +17,15 @@
 package com.netflix.spinnaker.config
 
 import com.netflix.spinnaker.orca.dryrun.DryRunStage
+import com.netflix.spinnaker.orca.listeners.ExecutionListener
+import com.netflix.spinnaker.orca.listeners.Persister
 import com.netflix.spinnaker.orca.pipeline.DefaultStageDefinitionBuilderFactory
 import com.netflix.spinnaker.orca.pipeline.StageDefinitionBuilder
 import com.netflix.spinnaker.orca.pipeline.StageDefinitionBuilderFactory
+import com.netflix.spinnaker.orca.pipeline.model.Execution
 import com.netflix.spinnaker.orca.pipeline.model.Pipeline
 import com.netflix.spinnaker.orca.pipeline.model.Stage
+import com.netflix.spinnaker.orca.pipeline.persistence.ExecutionRepository
 import org.slf4j.LoggerFactory
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty
 import org.springframework.boot.context.properties.EnableConfigurationProperties
@@ -53,5 +57,15 @@ open class DryRunConfiguration {
     }
   }
 
+  @Bean
+  open fun dryRunPipelineInitializer(repository: ExecutionRepository) = object : ExecutionListener {
+    override fun beforeExecution(persister: Persister, execution: Execution<out Execution<*>>) {
+      if (execution is Pipeline && execution.trigger["type"] == "dryrun") {
+        execution.pipelineConfigId = null
+        repository.store(execution)
+      }
+    }
+  }
+
   private val log = LoggerFactory.getLogger(javaClass)
 }