Merge pull request #1428 from memphisdev/RND-110-scaling-in-out-funct…

…ion-consumers RND-110-scaling-in-out-function-consumers
superstreamlabs · Nov 20, 2023 · 4392fe0 · 4392fe0
2 parents 1746192 + 068441f
commit 4392fe0
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/server/background_tasks.go b/server/background_tasks.go
@@ -342,6 +342,7 @@ func (s *Server) StartBackgroundTasks() error {
 	go s.CheckBrokenConnectedIntegrations()
 	go s.ReleaseStuckLocks()
 	go s.ConsumeFunctionTasks()
+	go s.ScaleFunctionWorkers()
 	return nil
 }
 

diff --git a/server/memphis_cloud.go b/server/memphis_cloud.go
@@ -2400,3 +2400,7 @@ func (pmh PoisonMessagesHandler) GetDlsMsgsByStationLight(station models.Station
 	}
 	return poisonMessages, schemaMessages, functionsMessages, totalDlsAmount, nil
 }
+
+func (s *Server) ScaleFunctionWorkers() {
+	return
+}
-Original file line number
+Diff line change
@@ Expand Up @@
     	}
     	return poisonMessages, schemaMessages, functionsMessages, totalDlsAmount, nil
     }
+    func (s *Server) ScaleFunctionWorkers() {
+    	return
+    }