src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java [367:374]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    try {
      JobState state = getLatestJobState();
      LOG.info("Job {} is in state {}", job().getId(), state);
      if (JobState.FAILED_STATES.contains(state)) {
        throw new RuntimeException(
            String.format(
                "Job ID %s under %s failed. Please check cloud console for more details.",
                job().getId(), job().getProjectId()));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java [391:398]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    try {
      JobState state = getLatestJobState();
      LOG.info("Job {} is in state {}", job().getId(), state);
      if (JobState.FAILED_STATES.contains(state)) {
        throw new RuntimeException(
            String.format(
                "Job ID %s under %s failed. Please check cloud console for more details.",
                job().getId(), job().getProjectId()));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -