Handle the startup case for rate limiter creation (#1229)

slackhq · Feb 10, 2025 · 6e30b28 · 6e30b28
1 parent f60e4e5
commit 6e30b28
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/astra/src/main/java/com/slack/astra/bulkIngestApi/DatasetRateLimitingService.java b/astra/src/main/java/com/slack/astra/bulkIngestApi/DatasetRateLimitingService.java
@@ -76,7 +76,7 @@ private void updatePreprocessorCount() {
     }
 
     // Only recreate the rate limiter if we have to
-    if (preprocessorCountValue == lastKnownPreprocessorCount) {
+    if (preprocessorCountValue == lastKnownPreprocessorCount && rateLimiterPredicate != null) {
       return;
     }