File tree Expand file tree Collapse file tree 2 files changed +5
-3
lines changed
main/java/io/airbyte/workers/temporal/scheduling
test/java/io/airbyte/workers/temporal/scheduling Expand file tree Collapse file tree 2 files changed +5
-3
lines changed Original file line number Diff line number Diff line change 10
10
import jakarta .inject .Singleton ;
11
11
import java .io .IOException ;
12
12
import java .util .UUID ;
13
- import lombok .AllArgsConstructor ;
14
13
import lombok .extern .slf4j .Slf4j ;
15
14
16
15
/**
19
18
*/
20
19
@ Singleton
21
20
@ Slf4j
22
- @ AllArgsConstructor
23
21
public class RouterService {
24
22
25
23
private final ConfigRepository configRepository ;
26
24
private final GeographyMapper geographyMapper ;
27
25
26
+ public RouterService (final ConfigRepository configRepository , final GeographyMapper geographyMapper ) {
27
+ this .configRepository = configRepository ;
28
+ this .geographyMapper = geographyMapper ;
29
+ }
30
+
28
31
/**
29
32
* Given a connectionId, look up the connection's configured {@link Geography} in the config DB and
30
33
* use it to determine which Task Queue should be used for this connection's sync.
Original file line number Diff line number Diff line change 8
8
9
9
import io .airbyte .commons .temporal .scheduling .GeographyMapper ;
10
10
import io .airbyte .config .Geography ;
11
- import io .airbyte .workers .temporal .scheduling .DefaultGeographyMapper ;
12
11
import java .util .Arrays ;
13
12
import java .util .Set ;
14
13
import java .util .stream .Collectors ;
You can’t perform that action at this time.
0 commit comments