From 6e30b2843e4d618360db365ca70109abce4250fc Mon Sep 17 00:00:00 2001
From: Kyle <1023070+kyle-sammons@users.noreply.github.com>
Date: Mon, 10 Feb 2025 10:09:55 -0800
Subject: [PATCH] Handle the startup case for rate limiter creation (#1229)

---
 .../slack/astra/bulkIngestApi/DatasetRateLimitingService.java   | 2 +-
 1 file changed, 1 insertion(+), 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
index 5aff7e9590..f5b29a1079 100644
--- 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;
     }