diff --git a/airbyte-bootloader/src/main/java/io/airbyte/bootloader/BootloaderApp.java b/airbyte-bootloader/src/main/java/io/airbyte/bootloader/BootloaderApp.java index 147ea9c3420fa..e1879919c5d02 100644 --- a/airbyte-bootloader/src/main/java/io/airbyte/bootloader/BootloaderApp.java +++ b/airbyte-bootloader/src/main/java/io/airbyte/bootloader/BootloaderApp.java @@ -55,10 +55,10 @@ public class BootloaderApp { private final Configs configs; private Runnable postLoadExecution; - private FeatureFlags featureFlags; + private final FeatureFlags featureFlags; @VisibleForTesting - public BootloaderApp(Configs configs, FeatureFlags featureFlags) { + public BootloaderApp(final Configs configs, final FeatureFlags featureFlags) { this.configs = configs; this.featureFlags = featureFlags; } @@ -71,7 +71,7 @@ public BootloaderApp(Configs configs, FeatureFlags featureFlags) { * @param configs * @param postLoadExecution */ - public BootloaderApp(Configs configs, Runnable postLoadExecution, FeatureFlags featureFlags) { + public BootloaderApp(final Configs configs, final Runnable postLoadExecution, final FeatureFlags featureFlags) { this.configs = configs; this.postLoadExecution = postLoadExecution; this.featureFlags = featureFlags; @@ -87,7 +87,7 @@ public BootloaderApp() { final ConfigPersistence configPersistence = DatabaseConfigPersistence.createWithValidation(configDatabase); configPersistence.loadData(YamlSeedConfigPersistence.getDefault()); LOGGER.info("Loaded seed data.."); - } catch (IOException e) { + } catch (final IOException e) { e.printStackTrace(); } }; @@ -134,7 +134,7 @@ public void load() throws Exception { LOGGER.info("Finished bootstrapping Airbyte environment.."); } - public static void main(String[] args) throws Exception { + public static void main(final String[] args) throws Exception { final var bootloader = new BootloaderApp(); bootloader.load(); } @@ -168,7 +168,8 @@ private static void createWorkspaceIfNoneExists(final ConfigRepository configRep configRepository.writeStandardWorkspace(workspace); } - private static void assertNonBreakingMigration(JobPersistence jobPersistence, AirbyteVersion airbyteVersion) throws IOException { + private static void assertNonBreakingMigration(final JobPersistence jobPersistence, final AirbyteVersion airbyteVersion) + throws IOException { // version in the database when the server main method is called. may be empty if this is the first // time the server is started. LOGGER.info("Checking illegal upgrade.."); @@ -221,7 +222,7 @@ private static void runFlywayMigration(final Configs configs, final Database con private static void cleanupZombies(final JobPersistence jobPersistence) throws IOException { final Configs configs = new EnvConfigs(); - WorkflowClient wfClient = + final WorkflowClient wfClient = WorkflowClient.newInstance(WorkflowServiceStubs.newInstance( WorkflowServiceStubsOptions.newBuilder().setTarget(configs.getTemporalHost()).build())); for (final Job zombieJob : jobPersistence.listJobsWithStatus(JobStatus.RUNNING)) {