diff --git a/common/src/main/java/com/google/udmi/util/SiteModel.java b/common/src/main/java/com/google/udmi/util/SiteModel.java
index 4d5fd0a735..169355de01 100644
--- a/common/src/main/java/com/google/udmi/util/SiteModel.java
+++ b/common/src/main/java/com/google/udmi/util/SiteModel.java
@@ -202,6 +202,15 @@ public String getRegistryId() {
     return executionConfiguration.registry_id;
   }
 
+  /**
+   * Get the reflect region name
+   *
+   * @return reflect region
+   */
+  public String getReflectRegion() {
+    return executionConfiguration.reflect_region;
+  }
+
   /**
    * Get the cloud region for this model.
    *
diff --git a/validator/src/main/java/com/google/daq/mqtt/sequencer/SequenceBase.java b/validator/src/main/java/com/google/daq/mqtt/sequencer/SequenceBase.java
index 6d4787ea95..d83e171004 100644
--- a/validator/src/main/java/com/google/daq/mqtt/sequencer/SequenceBase.java
+++ b/validator/src/main/java/com/google/daq/mqtt/sequencer/SequenceBase.java
@@ -207,6 +207,8 @@ static void ensureValidatorConfig() {
             .orElse(model.getCloudRegion());
         validatorConfig.registry_id = Optional.ofNullable(validatorConfig.registry_id)
             .orElse(model.getRegistryId());
+        validatorConfig.reflect_region = Optional.ofNullable(validatorConfig.reflect_region)
+            .orElse(model.getReflectRegion());
       } catch (Exception e) {
         throw new RuntimeException("While loading " + configFile, e);
       }