fix: making propagation region specific

Shuffle · Apr 5, 2024 · cf3e189 · cf3e189
1 parent 6ba490c
commit cf3e189
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/db-connector.go b/db-connector.go
@@ -3871,9 +3871,11 @@ func propagateApp(appId string, delete bool) error {
 	if len(propagateUrl) == 0 || len(propagateToken) == 0 {
 		return errors.New("no SHUFFLE_PROPAGATE_URL or SHUFFLE_PROPAGATE_TOKEN provided")
 	}
+	// SHUFFLE_GCE_LOCATION
+	gceRegion := os.Getenv("SHUFFLE_GCEPROJECT_LOCATION")
 
 	log.Printf("[INFO] Asking %s to propagate app %s", propagateUrl, appId)
-	data := map[string]string{"mode": "app", "appId": appId}
+	data := map[string]string{"mode": "app", "appId": appId, "region": gceRegion}
 
 	reqBody, err := json.Marshal(data)
 	if err != nil {