private List listMessages()

in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MetricsManager.java [287:302]

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

  private List<JobMessage> listMessages(
      String project, String region, String jobId, String minimumImportance) {
    LOG.info("Listing messages of {} under {}", jobId, project);
    ListJobMessagesResponse response =
        Failsafe.with(RetryUtil.clientRetryPolicy())
            .get(
                () ->
                    jobsClient()
                        .messages()
                        .list(project, region, jobId)
                        .setMinimumImportance(minimumImportance)
                        .execute());
    List<JobMessage> messages = response.getJobMessages();
    LOG.info("Received {} messages for {} under {}", messages.size(), jobId, project);
    return messages;
  }