Skip to content

Commit

Permalink
Fix formatting.
Browse files Browse the repository at this point in the history
  • Loading branch information
Geert Zondervan committed Dec 13, 2023
1 parent d2f5e80 commit da20a87
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@ package io.tolgee.batch

import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
import io.tolgee.Metrics
import io.tolgee.batch.data.ExecutionQueueItem
import io.tolgee.batch.data.BatchJobChunkExecutionDto
import io.tolgee.batch.data.ExecutionQueueItem
import io.tolgee.batch.data.QueueEventType
import io.tolgee.batch.events.JobQueueItemsEvent
import io.tolgee.component.UsingRedisProvider
Expand Down Expand Up @@ -48,7 +48,7 @@ class BatchJobChunkExecutionQueue(

@Scheduled(fixedDelay = 60000, initialDelay = 0)
fun populateQueue() {
logger.info("Running scheduled populate queue")
logger.debug("Running scheduled populate queue")
val data = entityManager.createQuery(
"""
select new io.tolgee.batch.data.BatchJobChunkExecutionDto(bjce.id, bk.id, bjce.executeAfter, bk.jobCharacter)
Expand All @@ -69,7 +69,7 @@ class BatchJobChunkExecutionQueue(
addExecutionsToLocalQueue(data)
}
}

fun addExecutionsToLocalQueue(data: List<BatchJobChunkExecutionDto>) {
val ids = queue.map { it.chunkExecutionId }.toSet()
var count = 0
Expand All @@ -80,7 +80,7 @@ class BatchJobChunkExecutionQueue(
}
}

logger.debug("Added ${count} new items to queue ${System.identityHashCode(this)}")
logger.debug("Added $count new items to queue ${System.identityHashCode(this)}")
}

fun addItemsToLocalQueue(data: List<ExecutionQueueItem>) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ import java.util.Date
*
* @author Geert Zondervan <zondervan@serviceplanet.nl>
*/
class BatchJobChunkExecutionDto (
class BatchJobChunkExecutionDto(
val id: Long,
val batchJobId: Long,
var executeAfter: Date?,
Expand Down

0 comments on commit da20a87

Please sign in to comment.