Skip to content

Commit

Permalink
Fix typos in QueueWorker log messages (#115)
Browse files Browse the repository at this point in the history
  • Loading branch information
heldersrvio authored Aug 29, 2022
1 parent 8c13f6f commit c95c891
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions Sources/Queues/QueueWorker.swift
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ public struct QueueWorker {
// If the job has a delay, we must check to make sure we can execute.
// If the delay has not passed yet, requeue the job
if let delay = data.delayUntil, delay >= Date() {
logger.trace("Requeing job \(id) for execution later because the delayUntil value of \(delay) has not passed yet")
logger.trace("Requeueing job \(id) for execution later because the delayUntil value of \(delay) has not passed yet")
return self.queue.push(id)
}

Expand All @@ -50,7 +50,7 @@ public struct QueueWorker {
logger.error("Could not send didDequeue notification: \(error)")
return self.queue.eventLoop.future()
}.flatMap { _ in
logger.info("Dequeing job", metadata: [
logger.info("Dequeueing job", metadata: [
"job_id": .string(id.string),
"job_name": .string(data.jobName),
"queue": .string(self.queue.queueName.string)
Expand Down

0 comments on commit c95c891

Please sign in to comment.