func GetCdPipeline()

in controllers/stage/chain/util/util.go [16:33]

• 15 lines of code
• 4 McCabe index (conditional complexity)

func GetCdPipeline(k8sClient client.Client, stage *cdPipeApi.Stage) (*cdPipeApi.CDPipeline, error) {
	ownerPipe := helper.GetOwnerReference(consts.CDPipelineKind, stage.GetOwnerReferences())
	if ownerPipe != nil {
		pipeline, err := cluster.GetCdPipeline(k8sClient, ownerPipe.Name, stage.Namespace)
		if err != nil {
			return nil, fmt.Errorf("failed to get owner pipeline : %w", err)
		}

		return pipeline, nil
	}

	pipeline, err := cluster.GetCdPipeline(k8sClient, stage.Spec.CdPipeline, stage.Namespace)
	if err != nil {
		return nil, fmt.Errorf("failed to get pipeline: %w", err)
	}

	return pipeline, nil
}