override def leaseLost()

in src/main/scala/com/gu/kinesis/RecordProcessorImpl.scala [128:136]

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

  override def leaseLost(leaseLostInput: LeaseLostInput): Unit = {
    log.info(s"Lease lost: $shardId")
    shutdown(
      ShutdownInput
        .builder()
        .shutdownReason(ShutdownReason.LEASE_LOST)
        .build()
    )
  }