From 607e0d28b51f8cb3b17e3dcdbf2fd8a0d1056698 Mon Sep 17 00:00:00 2001 From: Samuel Tariku Date: Wed, 13 Aug 2025 16:21:15 +0300 Subject: [PATCH] fix: temporarily stopping fetching --- internal/web_server/cron.go | 28 ++++++++++++++-------------- 1 file changed, 14 insertions(+), 14 deletions(-) diff --git a/internal/web_server/cron.go b/internal/web_server/cron.go index bbb8f67..ba95002 100644 --- a/internal/web_server/cron.go +++ b/internal/web_server/cron.go @@ -64,23 +64,23 @@ func StartDataFetchingCrons(eventService eventsvc.Service, oddsService oddssvc.S // } // }, // }, - { - spec: "0 */15 * * * *", // Every 15 Minutes - task: func() { - mongoLogger.Info("Fetching results for upcoming events") - if err := resultService.FetchAndProcessResults(context.Background()); err != nil { - mongoLogger.Error("Failed to process result", - zap.Error(err), - ) - } else { - mongoLogger.Info("Successfully processed all event result outcomes") - } - }, - }, + // { + // spec: "0 */15 * * * *", // Every 15 Minutes + // task: func() { + // mongoLogger.Info("Fetching results for upcoming events") + // if err := resultService.FetchAndProcessResults(context.Background()); err != nil { + // mongoLogger.Error("Failed to process result", + // zap.Error(err), + // ) + // } else { + // mongoLogger.Info("Successfully processed all event result outcomes") + // } + // }, + // }, } for _, job := range schedule { - job.task() + // job.task() if _, err := c.AddFunc(job.spec, job.task); err != nil { mongoLogger.Error("Failed to schedule data fetching cron job", zap.Error(err),