Skip to content

Commit

Permalink
fix(log): minor log refactor
Browse files Browse the repository at this point in the history
  • Loading branch information
kirangodishala committed Dec 13, 2024
1 parent 3b3894b commit ddf724e
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -512,7 +512,6 @@ class SqlExecutionRepository(

val finalResult: MutableList<String> = mutableListOf()

log.info("getting execution ids")
withPool(poolName) {
val baseQuery = jooq.select(field("config_id"), field("id"))
.from(table)
Expand Down Expand Up @@ -570,7 +569,7 @@ class SqlExecutionRepository(
.queryTimeout(queryTimeoutSeconds) // add an explicit timeout so that the query doesn't run forever
.fetch()

log.info("getting stage information for all the executions found so far")
log.debug("getting stage information for all the executions found so far")
return ExecutionMapper(mapper, stageReadSize,compressionProperties, pipelineRefEnabled).map(baseQuery.intoResultSet(), jooq)
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -607,9 +607,9 @@ class TaskController {

// get all relevant pipeline and strategy configs from front50
def pipelineConfigIds = front50Service.getPipelines(application, false)*.id as List<String>
log.info("received ${pipelineConfigIds.size()} pipelines for application: $application from front50")
log.debug("received ${pipelineConfigIds.size()} pipelines for application: $application from front50")
def strategyConfigIds = front50Service.getStrategies(application)*.id as List<String>
log.info("received ${strategyConfigIds.size()} strategies for application: $application from front50")
log.debug("received ${strategyConfigIds.size()} strategies for application: $application from front50")

def allFront50PipelineConfigIds = pipelineConfigIds + strategyConfigIds

Expand All @@ -628,11 +628,11 @@ class TaskController {

allPipelineExecutions.sort(startTimeOrId)
if (!expand) {
log.info("unexpanding pipeline executions")
log.debug("unexpanding pipeline executions")
unexpandPipelineExecutions(allPipelineExecutions)
}

log.info("filtering pipelines by history")
log.debug("filtering pipelines by history")
return filterPipelinesByHistoryCutoff(allPipelineExecutions, limit)
}

Expand Down

0 comments on commit ddf724e

Please sign in to comment.