@@ -0,0 +1,893 @@
+package com.hubspot.singularity.scheduler;%0A%0Aimport java.util.concurrent.TimeUnit;%0A%0Aimport javax.inject.Inject;%0Aimport javax.inject.Singleton;%0A%0Aimport org.slf4j.Logger;%0Aimport org.slf4j.LoggerFactory;%0A%0Aimport com.hubspot.singularity.config.SingularityConfiguration;%0A%0A@Singleton%0Apublic class SingularityUpstreamPoller extends SingularityLeaderOnlyPoller %7B%0A  private static final Logger LOG = LoggerFactory.getLogger(SingularityUpstreamPoller.class);%0A%0A  private final SingularityUpstreamChecker upstreamChecker;%0A%0A  @Inject%0A  SingularityUpstreamPoller(SingularityConfiguration configuration, SingularityUpstreamChecker upstreamChecker) %7B%0A    super(configuration.getCheckUpstreamsEverySeconds(), TimeUnit.SECONDS, true);%0A%0A    this.upstreamChecker = upstreamChecker;%0A%0A  %7D%0A%0A  @Override%0A  public void runActionOnPoll() %7B%0A    LOG.info(%22Checking upstreams%22);%0A    upstreamChecker.checkUpstreams();%0A  %7D%0A%7D%0A

add a singularity upstream poller