diff --git a/backend/go-app/go.mod b/backend/go-app/go.mod
index aa46d20c..cfa07b93 100644
--- a/backend/go-app/go.mod
+++ b/backend/go-app/go.mod
@@ -20,7 +20,7 @@ require (
 	github.com/gorilla/mux v1.8.1
 	github.com/h2non/filetype v1.1.3
 	github.com/satori/go.uuid v1.2.0
-	github.com/shuffle/shuffle-shared v0.6.29
+	github.com/shuffle/shuffle-shared v0.6.30
 	golang.org/x/crypto v0.22.0
 	google.golang.org/api v0.176.1
 	google.golang.org/grpc v1.63.2
diff --git a/backend/go-app/main.go b/backend/go-app/main.go
index 020d0258..525a4b3e 100755
--- a/backend/go-app/main.go
+++ b/backend/go-app/main.go
@@ -4887,7 +4887,7 @@ func initHandlers() {
 	}
 
 	for {
-		_, err = shuffle.RunInit(*shuffle.GetDatastore(), *shuffle.GetStorage(), gceProject, "onprem", true, elasticConfig)
+		_, err = shuffle.RunInit(*shuffle.GetDatastore(), *shuffle.GetStorage(), gceProject, "onprem", true, elasticConfig, false, 0)
 		if err != nil {
 			log.Printf("[ERROR] Error in initial database connection. Retrying in 5 seconds. %s", err)
 			time.Sleep(5 * time.Second)
diff --git a/backend/go-app/main_test.go b/backend/go-app/main_test.go
index 4e39ea0e..e40dba2b 100755
--- a/backend/go-app/main_test.go
+++ b/backend/go-app/main_test.go
@@ -34,7 +34,7 @@ func init() {
 		log.Fatalf("[DEBUG] Database client error during init: %s", err)
 	}
 
-	_, err = shuffle.RunInit(*dbclient, storage.Client{}, gceProject, "onprem", true, "elasticsearch")
+	_, err = shuffle.RunInit(*dbclient, storage.Client{}, gceProject, "onprem", true, "elasticsearch", false, 0)
 	log.Printf("INIT")
 }
 
diff --git a/functions/onprem/worker/go.mod b/functions/onprem/worker/go.mod
index e614e2f9..248a40f5 100644
--- a/functions/onprem/worker/go.mod
+++ b/functions/onprem/worker/go.mod
@@ -6,7 +6,7 @@ require (
 	github.com/docker/docker v26.1.0+incompatible
 	github.com/gorilla/mux v1.8.1
 	github.com/satori/go.uuid v1.2.0
-	github.com/shuffle/shuffle-shared v0.6.29
+	github.com/shuffle/shuffle-shared v0.6.30
 	k8s.io/api v0.30.0
 	k8s.io/apimachinery v0.30.0
 	k8s.io/client-go v0.30.0
diff --git a/functions/onprem/worker/worker.go b/functions/onprem/worker/worker.go
index 89153b11..3d66a1db 100644
--- a/functions/onprem/worker/worker.go
+++ b/functions/onprem/worker/worker.go
@@ -2980,7 +2980,7 @@ func getStreamResultsWrapper(client *http.Client, req *http.Request, workflowExe
 func main() {
 	// Elasticsearch necessary to ensure we'ren ot running with Datastore configurations for minimal/maximal data sizes
 	// Recursive import kind of :)
-	_, err := shuffle.RunInit(*shuffle.GetDatastore(), *shuffle.GetStorage(), "", "worker", true, "elasticsearch")
+	_, err := shuffle.RunInit(*shuffle.GetDatastore(), *shuffle.GetStorage(), "", "worker", true, "elasticsearch", false, 0)
 	if err != nil {
 		if !strings.Contains(fmt.Sprintf("%s", err), "no such host") {
 			log.Printf("[ERROR] Failed to run worker init: %s", err)