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;