diff --git a/main.go b/main.go index 48be8fe..9b2c525 100644 --- a/main.go +++ b/main.go @@ -200,7 +200,8 @@ func main() { // Initialize the bulk subscriber importer. importNotifCB := func(subject string, data map[string]interface{}) error { - return sendNotification(notifTplImport, subject, data, app) + go sendNotification(notifTplImport, subject, data, app) + return nil } app.Importer = subimporter.New(q.UpsertSubscriber.Stmt, q.UpsertBlacklistSubscriber.Stmt, diff --git a/subimporter/importer.go b/subimporter/importer.go index 5b94c77..a0a5116 100644 --- a/subimporter/importer.go +++ b/subimporter/importer.go @@ -277,12 +277,10 @@ func (s *Session) Start() { if cur == 0 { s.im.setStatus(StatusFinished) s.log.Printf("imported finished") - s.im.sendNotif(StatusFinished) - if _, err := s.im.updateListDate.Exec(listIDs); err != nil { s.log.Printf("error updating lists date: %v", err) } - + s.im.sendNotif(StatusFinished) return } @@ -298,11 +296,10 @@ func (s *Session) Start() { s.im.incrementImportCount(cur) s.im.setStatus(StatusFinished) s.log.Printf("imported finished") - s.im.sendNotif(StatusFinished) - if _, err := s.im.updateListDate.Exec(listIDs); err != nil { s.log.Printf("error updating lists date: %v", err) } + s.im.sendNotif(StatusFinished) } // Stop stops an active import session.