public void checkReplication()

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

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

  public void checkReplication() throws Exception {
    if (isReplicationDelayed()) {
      throw new NotReadyException("PostgreSQL replication is late");
    }
  }