private SelfScheduler initializeSelfScheduler()

in src/main/java/com/google/cloud/run/kafkascaler/KafkaScaler.java [100:111]

• 10 lines of code
• 1 McCabe index (conditional complexity)

  private SelfScheduler initializeSelfScheduler() throws IOException {
    CloudRunMetadataClient cloudRunMetadataClient = new CloudRunMetadataClient();

    ConfigurationProvider configProvider =
        new ConfigurationProvider(
            new ConfigurationProvider.SystemEnvProvider(), SCALING_CONFIG_FILE);

    return new SelfScheduler(
        new CloudTasksClientWrapper(CloudTasksClientWrapper.cloudTasksClient()),
        cloudRunMetadataClient,
        configProvider);
  }