in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java [188:197]
public Job getLatestJobView() {
LOG.info("Invoking latest job view");
return Failsafe.with(RetryUtil.clientRetryPolicy())
.get(
() ->
jobsClient()
.get(job().getProjectId(), job().getLocation(), job().getId())
.setView(JobView.JOB_VIEW_ALL.name())
.execute());
}