private static void quietlyStop(DiagnosticsManager diagnosticsManager) {
    try {
      diagnosticsManager.stop();
    } catch (InterruptedException e) {
      LOG.error("Exception while stopping diagnostics manager", e);
    }
  }
Wrapper around {@link DiagnosticsUtil#buildDiagnosticsManager} so it can be stubbed during testing.
samza-core/src/main/java/org/apache/samza/coordinator/staticresource/StaticResourceJobCoordinator.java