pass to fetcher in javafetcher

airbnb · Feb 21, 2024 · 1166f21 · 1166f21
1 parent caa220b
commit 1166f21
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/online/src/main/java/ai/chronon/online/JavaFetcher.java b/online/src/main/java/ai/chronon/online/JavaFetcher.java
@@ -26,6 +26,7 @@
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Map;
 import java.util.concurrent.CompletableFuture;
 import java.util.function.BiPredicate;
 import java.util.function.Consumer;
@@ -35,7 +36,7 @@ public class JavaFetcher {
   Fetcher fetcher;
 
   public JavaFetcher(KVStore kvStore, String metaDataSet, Long timeoutMillis, Consumer<LoggableResponse> logFunc, ExternalSourceRegistry registry, BiPredicate<String, Map<String, String>> featureFlags) {
-    this.fetcher = new Fetcher(kvStore, metaDataSet, timeoutMillis, logFunc, false, registry);
+    this.fetcher = new Fetcher(kvStore, metaDataSet, timeoutMillis, logFunc, false, registry, featureFlags);
   }
 
   public static List<JavaResponse> toJavaResponses(Seq<Response> responseSeq) {