Refactor server runJobs function. (#23854)

This commit is contained in:
dkkb
2023-12-22 16:51:40 +08:00
committed by GitHub
parent a59f5ccded
commit be24f108e1

View File

@@ -511,12 +511,6 @@ func NewServer(options ...Option) (*Server, error) {
}
if s.runEssentialJobs {
s.Go(func() {
appInstance := New(ServerConnector(s.Channels()))
s.runLicenseExpirationCheckJob()
runDNDStatusExpireJob(appInstance)
runPostReminderJob(appInstance)
})
s.runJobs()
}
@@ -538,6 +532,12 @@ func NewServer(options ...Option) (*Server, error) {
}
func (s *Server) runJobs() {
s.Go(func() {
appInstance := New(ServerConnector(s.Channels()))
s.runLicenseExpirationCheckJob()
runDNDStatusExpireJob(appInstance)
runPostReminderJob(appInstance)
})
s.Go(func() {
runSecurityJob(s)
})