From 9c79c5a2a8f7baa33036db65ac93a5c08b61a698 Mon Sep 17 00:00:00 2001 From: pmossman Date: Wed, 19 Oct 2022 08:07:53 -0700 Subject: [PATCH] remove all args constructor and extranneous import --- .../airbyte/workers/temporal/scheduling/RouterService.java | 7 +++++-- .../temporal/scheduling/DefaultGeographyMapperTest.java | 1 - 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/airbyte-workers/src/main/java/io/airbyte/workers/temporal/scheduling/RouterService.java b/airbyte-workers/src/main/java/io/airbyte/workers/temporal/scheduling/RouterService.java index fa122edc192d..df3321e126f4 100644 --- a/airbyte-workers/src/main/java/io/airbyte/workers/temporal/scheduling/RouterService.java +++ b/airbyte-workers/src/main/java/io/airbyte/workers/temporal/scheduling/RouterService.java @@ -10,7 +10,6 @@ import jakarta.inject.Singleton; import java.io.IOException; import java.util.UUID; -import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; /** @@ -19,12 +18,16 @@ */ @Singleton @Slf4j -@AllArgsConstructor public class RouterService { private final ConfigRepository configRepository; private final GeographyMapper geographyMapper; + public RouterService(final ConfigRepository configRepository, final GeographyMapper geographyMapper) { + this.configRepository = configRepository; + this.geographyMapper = geographyMapper; + } + /** * Given a connectionId, look up the connection's configured {@link Geography} in the config DB and * use it to determine which Task Queue should be used for this connection's sync. diff --git a/airbyte-workers/src/test/java/io/airbyte/workers/temporal/scheduling/DefaultGeographyMapperTest.java b/airbyte-workers/src/test/java/io/airbyte/workers/temporal/scheduling/DefaultGeographyMapperTest.java index f9805ecaaeb7..05d1ad6c1124 100644 --- a/airbyte-workers/src/test/java/io/airbyte/workers/temporal/scheduling/DefaultGeographyMapperTest.java +++ b/airbyte-workers/src/test/java/io/airbyte/workers/temporal/scheduling/DefaultGeographyMapperTest.java @@ -8,7 +8,6 @@ import io.airbyte.commons.temporal.scheduling.GeographyMapper; import io.airbyte.config.Geography; -import io.airbyte.workers.temporal.scheduling.DefaultGeographyMapper; import java.util.Arrays; import java.util.Set; import java.util.stream.Collectors;