From 3f7c13a6bec3cf16c01110fbf15c8b57aed67afa Mon Sep 17 00:00:00 2001 From: Bel LaPointe <153096461+breel-render@users.noreply.github.com> Date: Sat, 24 May 2025 14:13:18 -0600 Subject: [PATCH] add logs --- scheduler/scheduler.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/scheduler/scheduler.go b/scheduler/scheduler.go index a641bda..aeec274 100755 --- a/scheduler/scheduler.go +++ b/scheduler/scheduler.go @@ -27,12 +27,19 @@ type Scheduler struct { type semaphored struct { job cron.Job ch chan struct{} + l logger.Logger } func (s semaphored) Run() { + s.l.Info("scheduler.semaphored.Run() | acquiring...") s.ch <- struct{}{} + s.l.Info("scheduler.semaphored.Run() | acquired") + s.job.Run() + + s.l.Info("scheduler.semaphored.Run() | releasing...") <-s.ch + s.l.Info("scheduler.semaphored.Run() | released") } func New() *Scheduler { @@ -46,6 +53,7 @@ func New() *Scheduler { cron.Recover(l), func(j cron.Job) cron.Job { return semaphored{ + l: l, job: j, ch: semaphore, }