override def execute()

in app/services/notification/NotificationJob.scala [13:31]

• 19 lines of code
• 1 McCabe index (conditional complexity)

  override def execute(context: JobExecutionContext): Unit = {
    val schedulerContext = context.getScheduler.getContext
    val scheduledNotificationRunner = schedulerContext
      .get("ScheduledNotificationRunner")
      .asInstanceOf[ScheduledNotificationRunner]
    implicit val ec =
      schedulerContext.get("ExecutionContext").asInstanceOf[ExecutionContext]
    val result = scheduledNotificationRunner.run(new DateTime())
    Await
      .result(result.asFuture, 10.minutes)
      .fold(
        err =>
          logger
            .error(s"Failed to send scheduled notifications: ${err.logString}"),
        { msgs =>
          logger.info(s"Email notifications: ${msgs.size} sent")
        }
      )
  }