We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3af01de commit 9bfe03bCopy full SHA for 9bfe03b
airbyte-workers/src/main/java/io/airbyte/workers/helper/DefaultGeographyMapper.java
@@ -9,7 +9,9 @@
9
import io.airbyte.config.Geography;
10
import jakarta.inject.Singleton;
11
import java.util.Map;
12
+import lombok.extern.slf4j.Slf4j;
13
14
+@Slf4j
15
@Singleton
16
public class DefaultGeographyMapper implements GeographyMapper {
17
@@ -26,6 +28,7 @@ public class DefaultGeographyMapper implements GeographyMapper {
26
28
27
29
@Override
30
public String getTaskQueue(final Geography geography) {
31
+ log.warn("Called DefaultGeographyMapper getTaskQueue for geography {}", geography);
32
if (GEOGRAPHY_TASK_QUEUE_MAP.containsKey(geography)) {
33
return GEOGRAPHY_TASK_QUEUE_MAP.get(geography);
34
}
0 commit comments