test_class.declarator: CLUSTER_1 = Cluster.builder()
        .withName("cluster1")
        .withSeedHosts(ImmutableSet.of("127.0.0.1"))
        .withState(Cluster.State.ACTIVE)
        .build()
test_class.modifier: private static final
test_class.original_string: private static final Cluster CLUSTER_1 = Cluster.builder()
        .withName("cluster1")
        .withSeedHosts(ImmutableSet.of("127.0.0.1"))
        .withState(Cluster.State.ACTIVE)
        .build();
test_class.type: Cluster
test_class.var_name: CLUSTER_1
test_class.declarator: CLUSTER_2 = Cluster.builder()
        .withName("cluster2")
        .withSeedHosts(ImmutableSet.of("127.0.0.1"))
        .withState(Cluster.State.ACTIVE)
        .build()
test_class.modifier: private static final
test_class.original_string: private static final Cluster CLUSTER_2 = Cluster.builder()
        .withName("cluster2")
        .withSeedHosts(ImmutableSet.of("127.0.0.1"))
        .withState(Cluster.State.ACTIVE)
        .build();
test_class.type: Cluster
test_class.var_name: CLUSTER_2
test_class.declarator: context
test_class.modifier: private
test_class.original_string: private AppContext context;
test_class.type: AppContext
test_class.var_name: context
test_class.declarator: repairAutoSchedulingManager
test_class.modifier: private
test_class.original_string: private AutoSchedulingManager repairAutoSchedulingManager;
test_class.type: AutoSchedulingManager
test_class.var_name: repairAutoSchedulingManager
test_class.declarator: clusterRepairScheduler
test_class.modifier: private
test_class.original_string: private ClusterRepairScheduler clusterRepairScheduler;
test_class.type: ClusterRepairScheduler
test_class.var_name: clusterRepairScheduler
test_class.file: src/server/src/test/java/io/cassandrareaper/service/AutoSchedulingManagerTest.java
test_class.identifier: AutoSchedulingManagerTest
test_case.body: @Test
    public void continueProcessingOtherClusterWhenSchedulingFailsForACluster() throws Exception {
      context.storage.addCluster(CLUSTER_1);
      context.storage.addCluster(CLUSTER_2);
  
      doThrow(new RuntimeException("throw for test purposes")).when(clusterRepairScheduler).scheduleRepairs(CLUSTER_1);
  
      repairAutoSchedulingManager.run();
  
      verify(clusterRepairScheduler).scheduleRepairs(CLUSTER_1);
      verify(clusterRepairScheduler).scheduleRepairs(CLUSTER_2);
    }
test_case.class_method_signature: AutoSchedulingManagerTest.continueProcessingOtherClusterWhenSchedulingFailsForACluster()
test_case.full_signature: @Test public void continueProcessingOtherClusterWhenSchedulingFailsForACluster()
test_case.identifier: continueProcessingOtherClusterWhenSchedulingFailsForACluster
test_case.invocations: addCluster addCluster scheduleRepairs when doThrow run scheduleRepairs verify scheduleRepairs verify
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void continueProcessingOtherClusterWhenSchedulingFailsForACluster()
focal_class.declarator: LOG = LoggerFactory.getLogger(AutoSchedulingManager.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOG = LoggerFactory.getLogger(AutoSchedulingManager.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.declarator: repairAutoSchedulingManager
focal_class.modifier: private static
focal_class.original_string: private static AutoSchedulingManager repairAutoSchedulingManager;
focal_class.type: AutoSchedulingManager
focal_class.var_name: repairAutoSchedulingManager
focal_class.declarator: context
focal_class.modifier: private final
focal_class.original_string: private final AppContext context;
focal_class.type: AppContext
focal_class.var_name: context
focal_class.declarator: clusterRepairScheduler
focal_class.modifier: private final
focal_class.original_string: private final ClusterRepairScheduler clusterRepairScheduler;
focal_class.type: ClusterRepairScheduler
focal_class.var_name: clusterRepairScheduler
focal_class.file: src/server/src/main/java/io/cassandrareaper/service/AutoSchedulingManager.java
focal_class.identifier: AutoSchedulingManager
focal_class.class_method_signature: AutoSchedulingManager.AutoSchedulingManager(AppContext context)
focal_class.full_signature: private  AutoSchedulingManager(AppContext context)
focal_class.identifier: AutoSchedulingManager
focal_class.modifiers: private
focal_class.parameters: (AppContext context)
focal_class.signature:  AutoSchedulingManager(AppContext context)
focal_class.class_method_signature: AutoSchedulingManager.AutoSchedulingManager(AppContext context, ClusterRepairScheduler clusterRepairScheduler)
focal_class.full_signature: public  AutoSchedulingManager(AppContext context, ClusterRepairScheduler clusterRepairScheduler)
focal_class.identifier: AutoSchedulingManager
focal_class.modifiers: public
focal_class.parameters: (AppContext context, ClusterRepairScheduler clusterRepairScheduler)
focal_class.signature:  AutoSchedulingManager(AppContext context, ClusterRepairScheduler clusterRepairScheduler)
focal_class.class_method_signature: AutoSchedulingManager.start(AppContext context)
focal_class.full_signature: public static synchronized void start(AppContext context)
focal_class.identifier: start
focal_class.modifiers: public static synchronized
focal_class.parameters: (AppContext context)
focal_class.return: void
focal_class.signature: void start(AppContext context)
focal_class.class_method_signature: AutoSchedulingManager.run()
focal_class.full_signature: @Override public void run()
focal_class.identifier: run
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void run()
focal_class.superclass: extends TimerTask
focal_method.body: @Override
    public void run() {
      LOG.debug("Checking cluster keyspaces to identify which ones require repair schedules...");
      Collection<Cluster> clusters = context.storage.getClusters();
      for (Cluster cluster : clusters) {
        try {
          clusterRepairScheduler.scheduleRepairs(cluster);
        } catch (ReaperException | RuntimeException e) {
          LOG.error("Error while scheduling repairs for cluster {}", cluster, e);
        }
      }
    }
focal_method.class_method_signature: AutoSchedulingManager.run()
focal_method.full_signature: @Override public void run()
focal_method.identifier: run
focal_method.invocations: debug getClusters scheduleRepairs error
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: void
focal_method.signature: void run()