in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java [119:124]
public DataflowJobManager withJob(String project, String region, String jobId, String jobView) {
Job job =
Failsafe.with(RetryUtil.clientRetryPolicy())
.get(() -> jobsClient().get(project, region, jobId).setView(jobView).execute());
return toBuilder().setJob(job).build();
}