void run()

in src/com/epam/digital/data/platform/pipelines/stages/impl/dataplatform/DeleteDataServices.groovy [29:62]
34 lines of code
5 McCabe index (conditional complexity)

    void run() {
        context.dataComponents.values().each { dataComponent ->
            context.logger.info("Removing data components buildconfigs")
            String buildConfigName = dataComponent.codebaseName + '-' + dataComponent.codebaseBranch
            if (context.platform.checkObjectExists("buildconfig", buildConfigName)) {
                context.platform.deleteObject("buildconfig", buildConfigName)
            } else {
                context.logger.info("There is no buildconfig " + context.codebase.buildConfigName)
            }
            context.script.dir("${context.workDir}/${dataComponent.name}") {
                context.script.sshagent(["${context.gitServer.credentialsId}"]) {
                    context.logger.info("Checkout ${dataComponent.fullName}")
                    context.gitClient.gitSetConfig()
                    context.gitClient.checkout(dataComponent.repositoryPath, dataComponent.codebaseBranch,
                            context.gitServer.credentialsId)
                    context.script.sh(script: "git checkout ${dataComponent.codebaseBranch}")
                    String currentCommitMessage = context.gitClient.getCurrentCommitMessage()
                    if (currentCommitMessage.contains("generated")) {
                        Helm.uninstall(context, dataComponent.fullName, context.namespace, true)
                        if (dataComponent.name == DataComponentType.REST_API.getValue()) {
                            try {
                                context.logger.info("Removing kafka topics")
                                context.kafka.removeKafkaTopics()
                            } catch (any) {
                                context.script.error("Cannot gracefully remove kafka topics")
                            }
                        }
                        context.gitClient.gitResetHardToPreviousCommit()
                        context.gitClient.gitPushForce(dataComponent.codebaseBranch)
                    }
                }
            }
        }
    }