fix

Helicone · Sep 19, 2024 · 556242f · 556242f
1 parent 2d60357
commit 556242f
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/valhalla/jawn/src/index.ts b/valhalla/jawn/src/index.ts
@@ -62,10 +62,10 @@ const KAFKA_ENABLED = (KAFKA_CREDS?.KAFKA_ENABLED ?? "false") === "true";
 
 if (KAFKA_ENABLED) {
   startConsumers({
-    dlqCount: DLQ_WORKER_COUNT,
-    normalCount: NORMAL_WORKER_COUNT,
-    scoresCount: SCORES_WORKER_COUNT,
-    scoresDlqCount: SCORES_WORKER_COUNT,
+    dlqCount: 0,
+    normalCount: 0,
+    scoresCount: 0,
+    scoresDlqCount: 0,
     backFillCount: 0,
   });
 }

diff --git a/valhalla/jawn/src/lib/stores/ScoreStore.ts b/valhalla/jawn/src/lib/stores/ScoreStore.ts
@@ -105,7 +105,7 @@ export class ScoreStore extends BaseStore {
   ): Promise<Result<RequestResponseRMT[], string>> {
     const queryPlaceholders = newVersions
       .map((_, index) => {
-        const base = index * 3;
+        const base = index * 2;
         return `({val_${base} : String}, {val_${base + 1} : String})`;
       })
       .join(",\n    ");