feast-dev
diff --git a/‎serving/src/main/java/feast/serving/config/FeastProperties.java‎
Lines changed: 21 additions & 0 deletions b/‎serving/src/main/java/feast/serving/config/FeastProperties.java‎
Lines changed: 21 additions & 0 deletions
diff --git a/‎serving/src/main/java/feast/serving/config/SpecServiceConfig.java‎
Lines changed: 2 additions & 1 deletion b/‎serving/src/main/java/feast/serving/config/SpecServiceConfig.java‎
Lines changed: 2 additions & 1 deletion
diff --git a/‎serving/src/main/resources/application.yml‎
Lines changed: 1 addition & 0 deletions b/‎serving/src/main/resources/application.yml‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎serving/src/test/java/feast/serving/it/ServingServiceIT.java‎
Lines changed: 7 additions & 3 deletions b/‎serving/src/test/java/feast/serving/it/ServingServiceIT.java‎
Lines changed: 7 additions & 3 deletions
@@ -86,6 +86,9 @@ public void setCoreAuthentication(CoreAuthenticationProperties coreAuthenticatio
     this.coreAuthentication = coreAuthentication;
   }
 
+  /* Feast Core port to connect to. */
+  @Positive private int coreCacheRefreshInterval;
+
   private SecurityProperties security;
 
   @Bean
@@ -220,6 +223,24 @@ public void setCoreGrpcPort(int coreGrpcPort) {
     this.coreGrpcPort = coreGrpcPort;
   }
 
+  /**
+   * Gets CachedSpecService refresh interval.
+   *
+   * @return CachedSpecService refresh interval
+   */
+  public int getCoreCacheRefreshInterval() {
+    return coreCacheRefreshInterval;
+  }
+
+  /**
+   * Sets CachedSpecService refresh interval.
+   *
+   * @param coreCacheRefreshInterval CachedSpecService refresh interval
+   */
+  public void setCoreCacheRefreshInterval(int coreCacheRefreshInterval) {
+    this.coreCacheRefreshInterval = coreCacheRefreshInterval;
+  }
+
   /**
    * Sets the collection of configured stores.
    *
 
@@ -37,12 +37,13 @@ public class SpecServiceConfig {
   private static final Logger log = org.slf4j.LoggerFactory.getLogger(SpecServiceConfig.class);
   private String feastCoreHost;
   private int feastCorePort;
-  private static final int CACHE_REFRESH_RATE_SECONDS = 10;
+  private int CACHE_REFRESH_RATE_SECONDS;
 
   @Autowired
   public SpecServiceConfig(FeastProperties feastProperties) {
     feastCoreHost = feastProperties.getCoreHost();
     feastCorePort = feastProperties.getCoreGrpcPort();
+    CACHE_REFRESH_RATE_SECONDS = feastProperties.getCoreCacheRefreshInterval();
   }
 
   @Bean
 
@@ -17,6 +17,7 @@ feast:
       audience: https://localhost #token audience.
       jwkEndpointURI: <jwkEndpointURI> #jwk enpoint uri, used for caching token till expiry.
 
+  core-cache-refresh-interval: 10
 
   # Indicates the active store. Only a single store in the last can be active at one time. In the future this key
   # will be deprecated in order to allow multiple stores to be served from a single serving instance
 
@@ -60,7 +60,11 @@
 import org.testcontainers.junit.jupiter.Testcontainers;
 
 @ActiveProfiles("it")
-@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
+@SpringBootTest(
+    webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
+    properties = {
+      "feast.core-cache-refresh-interval=1",
+    })
 @Testcontainers
 public class ServingServiceIT extends BaseAuthIT {
 
@@ -441,9 +445,9 @@ public void shouldReturnNotFoundForUpdatedType() {
     TestUtils.applyFeatureTable(
         coreClient, projectName, featureTableName, entities, features, 7200);
 
-    // Sleep is necessary to ensure caching (every 10s) of updated FeatureTable is done
+    // Sleep is necessary to ensure caching (every 1s) of updated FeatureTable is done
     try {
-      Thread.sleep(15000);
+      Thread.sleep(2000);
     } catch (InterruptedException e) {
     }