From a7596ff33d6c9afd5efa911f6abb4e67d674b6ac Mon Sep 17 00:00:00 2001 From: skeris Date: Mon, 2 Dec 2024 21:45:54 +0300 Subject: [PATCH] debug --- internal/app/app.go | 4 +++- internal/workers/post_deals_worker/deals_worker.go | 2 ++ 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/internal/app/app.go b/internal/app/app.go index 5efbe90..7a0f8e5 100644 --- a/internal/app/app.go +++ b/internal/app/app.go @@ -21,6 +21,7 @@ import ( "errors" "penahub.gitlab.yandexcloud.net/backend/quiz/common.git/dal" "time" + "fmt" "go.uber.org/zap" ) @@ -28,7 +29,7 @@ import ( func Run(ctx context.Context, config initialize.Config, logger *zap.Logger) error { defer func() { if r := recover(); r != nil { - logger.Error("Recovered from a panic", zap.Any("error", r)) + logger.Error("Recovered in app from a panic", zap.Any("error", r)) } }() @@ -135,6 +136,7 @@ func Run(ctx context.Context, config initialize.Config, logger *zap.Logger) erro go dataUpdater.Start(ctx) go queUpdater.Start(ctx) + fmt.Println("UMBRELLA") go dealsPoster.Start(ctx) go fieldsPoster.Start(ctx) diff --git a/internal/workers/post_deals_worker/deals_worker.go b/internal/workers/post_deals_worker/deals_worker.go index 77cba5c..4d014e0 100644 --- a/internal/workers/post_deals_worker/deals_worker.go +++ b/internal/workers/post_deals_worker/deals_worker.go @@ -45,6 +45,7 @@ func NewPostDealsWC(deps Deps) *PostDeals { } func (wc *PostDeals) Start(ctx context.Context) { + fmt.Println("Start") ticker := time.NewTicker(1 * time.Minute) defer ticker.Stop() defer func() { @@ -60,6 +61,7 @@ func (wc *PostDeals) Start(ctx context.Context) { wc.startFetching(ctx) case <-ctx.Done(): + fmt.Println("Done") return } }