Rename GetCachedPipelineIds to GetByPipelineIds in WorkflowStatusLatestRepository and update references in CiHandlerImpl for clarity.

Author: prakash100198

internal/sql/repository/pipelineConfig/WorkflowStatusLatestRepository.go

@@ -28,7 +28,7 @@ type WorkflowStatusLatestRepository interface {
 	UpdateCiWorkflowStatusLatest(model *CiWorkflowStatusLatest) error
 	GetCiWorkflowStatusLatestByPipelineId(pipelineId int) (*CiWorkflowStatusLatest, error)
 	GetCiWorkflowStatusLatestByAppId(appId int) ([]*CiWorkflowStatusLatest, error)
-	GetCachedPipelineIds(pipelineIds []int) ([]int, error)
+	GetByPipelineIds(pipelineIds []int) ([]int, error)
 	GetCiWorkflowStatusLatestByPipelineIds(pipelineIds []int) ([]*CiWorkflowStatusLatest, error)
 	DeleteCiWorkflowStatusLatestByPipelineId(pipelineId int) error
 
@@ -129,7 +129,7 @@ func (impl *WorkflowStatusLatestRepositoryImpl) DeleteCiWorkflowStatusLatestByPi
 	return nil
 }
 
-func (impl *WorkflowStatusLatestRepositoryImpl) GetCachedPipelineIds(pipelineIds []int) ([]int, error) {
+func (impl *WorkflowStatusLatestRepositoryImpl) GetByPipelineIds(pipelineIds []int) ([]int, error) {
 	if len(pipelineIds) == 0 {
 		return []int{}, nil
 	}

pkg/pipeline/CiHandler.go

@@ -659,7 +659,7 @@ func (impl *CiHandlerImpl) FetchCiStatusForTriggerViewV1(appId int) ([]*pipeline
 	}
 
 	// Find which pipeline IDs have entries in latest status table
-	pipelinesInLatestTable, err := impl.workflowStatusLatestRepository.GetCachedPipelineIds(allPipelineIds)
+	pipelinesInLatestTable, err := impl.workflowStatusLatestRepository.GetByPipelineIds(allPipelineIds)
 	if err != nil {
 		impl.Logger.Errorw("error in checking latest status table, falling back to old method", "err", err, "appId", appId)
 		return impl.ciWorkflowRepository.FIndCiWorkflowStatusesByAppId(appId)
@@ -788,7 +788,7 @@ func (impl *CiHandlerImpl) fetchLastTriggeredWorkflowsHybrid(pipelineIds []int)
 	}
 
 	// Find which pipeline IDs have entries in latest status table
-	pipelinesInLatestTable, err := impl.workflowStatusLatestRepository.GetCachedPipelineIds(pipelineIds)
+	pipelinesInLatestTable, err := impl.workflowStatusLatestRepository.GetByPipelineIds(pipelineIds)
 	if err != nil {
 		impl.Logger.Errorw("error in checking latest status table, falling back to complex query", "err", err, "pipelineIds", pipelineIds)
 		return impl.ciWorkflowRepository.FindLastTriggeredWorkflowByCiIds(pipelineIds)