static boolean isReplicationDelayed()

in dbeam-core/src/main/java/com/spotify/dbeam/jobs/PsqlReplicationCheck.java [82:95]

• 14 lines of code
• 2 McCabe index (conditional complexity)

  static boolean isReplicationDelayed(
      final Instant partition,
      final Instant lastReplication,
      final TemporalAmount partitionPeriod) {
    final Instant partitionPlusPartitionPeriod = partitionPlusPeriod(partition, partitionPeriod);
    if (lastReplication.isBefore(partitionPlusPartitionPeriod)) {
      LOGGER.error(
          "Replication was not completed for partition, expected >= {}, actual = {}",
          partitionPlusPartitionPeriod,
          lastReplication);
      return true;
    }
    return false;
  }