private Optional<DiagnosticsManager> diagnosticsManager(JobModel jobModel) {
    JobConfig jobConfig = new JobConfig(this.config);
    String jobName = jobConfig.getName().orElseThrow(() -> new ConfigException("Missing job name"));
    return buildDiagnosticsManager(jobName, jobConfig.getJobId(), jobModel,
        CoordinationConstants.JOB_COORDINATOR_CONTAINER_NAME, this.executionEnvContainerId, this.samzaEpochId,
        this.config);
  }
This is a helper method so that we can verify it is called in testing.
samza-core/src/main/java/org/apache/samza/coordinator/staticresource/StaticResourceJobCoordinator.java