add recover to worker

2024-12-02 21:15:20 +03:00 · 2024-12-02 21:15:20 +03:00 · 75870273bd
commit 75870273bd
parent b375f8dbbc
1 changed files with 6 additions and 0 deletions
--- a/internal/workers/post_deals_worker/deals_worker.go
+++ b/internal/workers/post_deals_worker/deals_worker.go
@ -47,10 +47,16 @@ func NewPostDealsWC(deps Deps) *PostDeals {
 func (wc *PostDeals) Start(ctx context.Context) {
 	ticker := time.NewTicker(1 * time.Minute)
 	defer ticker.Stop()
+	defer func() {
+		if v:=recover();v!=nil{
+			fmt.Println("StartFetchingRecover",v)
+		}
+	} ()

 	for {
 		select {
 		case <-ticker.C:
+			fmt.Println("StartFetching")
 			wc.startFetching(ctx)

 		case <-ctx.Done():