jobCompleted method

void jobCompleted(
  1. String jobType,
  2. Duration processingTime, {
  3. JobPriority? priority,
})

Record job completed

Implementation

void jobCompleted(
  String jobType,
  Duration processingTime, {
  JobPriority? priority,
}) {
  totalCompleted++;
  currentlyProcessing--;
  lastActivity = DateTime.now();

  completedByType[jobType] = (completedByType[jobType] ?? 0) + 1;

  totalProcessingTimeByType[jobType] =
      (totalProcessingTimeByType[jobType] ?? Duration.zero) + processingTime;

  _recordProcessingTime(processingTime);

  if (priority != null) {
    completedByPriority[priority] = (completedByPriority[priority] ?? 0) + 1;
  }
}