diff --git a/server/background_tasks.go b/server/background_tasks.go index bce7fedb2..981a79e23 100644 --- 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 index c131feaea..887f61885 100644 --- 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 +}