From b66c49f3a9e515dead26426ff7299864d91199a3 Mon Sep 17 00:00:00 2001
From: e-ngo <52668908+e-ngo@users.noreply.github.com>
Date: Thu, 3 Jul 2025 05:46:21 -0700
Subject: [PATCH] Tune dragonfly to Remove Old Entries & Use Longtext to fit
 larger warming jobs (#4145)

* Tune dragonfly to fit our usecase by:

* use longtext to fit larger clusters

* fix scheduler and seed-client register logic

* Remove commented out lines.
---
 manager/models/models.go               | 4 ++--
 manager/rpcserver/manager_server_v2.go | 4 ----
 2 files changed, 2 insertions(+), 6 deletions(-)

diff --git a/manager/models/models.go b/manager/models/models.go
index e5d03834e..d29f2fbf3 100644
--- a/manager/models/models.go
+++ b/manager/models/models.go
@@ -88,7 +88,7 @@ func (m JSONMap) GormDataType() string {
 }
 
 func (JSONMap) GormDBDataType(db *gorm.DB, field *schema.Field) string {
-	return "text"
+	return "longtext"
 }
 
 type Array []string
@@ -137,5 +137,5 @@ func (Array) GormDataType() string {
 }
 
 func (Array) GormDBDataType(db *gorm.DB, field *schema.Field) string {
-	return "text"
+	return "longtext"
 }
diff --git a/manager/rpcserver/manager_server_v2.go b/manager/rpcserver/manager_server_v2.go
index 9de5ce882..df87809c7 100644
--- a/manager/rpcserver/manager_server_v2.go
+++ b/manager/rpcserver/manager_server_v2.go
@@ -238,8 +238,6 @@ func (s *managerServerV2) UpdateSeedPeer(ctx context.Context, req *managerv2.Upd
 	seedPeer := models.SeedPeer{}
 	if err := s.db.WithContext(ctx).First(&seedPeer, models.SeedPeer{
 		Hostname:          req.Hostname,
-		IP:                req.Ip,
-		Port:              req.Port,
 		SeedPeerClusterID: uint(req.SeedPeerClusterId),
 	}).Error; err != nil {
 		if errors.Is(err, gorm.ErrRecordNotFound) {
@@ -452,8 +450,6 @@ func (s *managerServerV2) UpdateScheduler(ctx context.Context, req *managerv2.Up
 	scheduler := models.Scheduler{}
 	if err := s.db.WithContext(ctx).First(&scheduler, models.Scheduler{
 		Hostname:           req.Hostname,
-		IP:                 req.Ip,
-		Port:               req.Port,
 		SchedulerClusterID: uint(req.SchedulerClusterId),
 	}).Error; err != nil {
 		if errors.Is(err, gorm.ErrRecordNotFound) {