fix: memory leak issue in invoice sync (#747)

raystack · Aug 27, 2024 · 4eb8455 · 4eb8455
1 parent b101b8a
commit 4eb8455
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/billing/invoice/service.go b/billing/invoice/service.go
@@ -61,7 +61,11 @@ func (s *Service) Init(ctx context.Context) error {
 		s.syncJob.Stop()
 	}
 
-	s.syncJob = cron.New()
+	s.syncJob = cron.New(cron.WithChain(
+		cron.SkipIfStillRunning(cron.DefaultLogger),
+		cron.Recover(cron.DefaultLogger),
+	))
+
 	if _, err := s.syncJob.AddFunc(fmt.Sprintf("@every %s", s.syncDelay.String()), func() {
 		ctx, cancel := context.WithCancel(ctx)
 		defer cancel()