feat(redis_migration): log if there are still pending orchestrations/…

…pipelines
spinnaker · Sep 19, 2017 · c1544dc · c1544dc
1 parent 65e322c
commit c1544dc
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 0 deletions.
diff --git a/...pinnaker/orca/front50/migrations/MultiRedisOrchestrationMigrationNotificationAgent.groovy b/...pinnaker/orca/front50/migrations/MultiRedisOrchestrationMigrationNotificationAgent.groovy
@@ -118,6 +118,16 @@ class MultiRedisOrchestrationMigrationNotificationAgent extends AbstractPollingN
         .single()
 
       if (migratableOrchestrations.isEmpty()) {
+        def pendingOrchestrations = executionRepositoryPrevious
+          .retrieveOrchestrationsForApplication(applicationName, executionCriteria)
+          .filter({ orchestration -> !orchestration.status.isComplete() })
+          .toList()
+          .toBlocking()
+          .single()
+
+        if (!pendingOrchestrations.isEmpty()) {
+          log.info("${pendingOrchestrations.size()} orchestrations yet to complete ${applicationName}) [${index}/${allApplications.size()}]")
+        }
         return
       }
 

diff --git a/...lix/spinnaker/orca/front50/migrations/MultiRedisPipelineMigrationNotificationAgent.groovy b/...lix/spinnaker/orca/front50/migrations/MultiRedisPipelineMigrationNotificationAgent.groovy
@@ -115,6 +115,16 @@ class MultiRedisPipelineMigrationNotificationAgent extends AbstractPollingNotifi
         .single()
 
       if (migratablePipelines.isEmpty()) {
+        def pendingPipelines = executionRepositoryPrevious
+          .retrievePipelinesForPipelineConfigId(pipelineConfigId, executionCriteria)
+          .filter({ pipeline -> !pipeline.status.isComplete() })
+          .toList()
+          .toBlocking()
+          .single()
+
+        if (!pendingPipelines.isEmpty()) {
+          log.info("${pendingPipelines.size()} pipelines yet to complete (${pipelineConfigId}) [${index}/${allPipelineConfigIds.size()}]")
+        }
         return
       }