diff options
| -rw-r--r-- | internal/server/scheduler.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/internal/server/scheduler.go b/internal/server/scheduler.go index 586ac0b..e0cecfd 100644 --- a/internal/server/scheduler.go +++ b/internal/server/scheduler.go @@ -99,8 +99,11 @@ func (s *scheduler) runJobs(ctx context.Context) { continue } + jobCtx, cancel := context.WithCancel(ctx) + defer cancel() + logger.Info(fmt.Sprintf("Starting scheduled job %s", scheduled.Name)) - status := client.Start(ctx) + status := client.Start(jobCtx) logMessage := fmt.Sprintf("Job exited with status %d", status) if err := os.Rename(tmpOutfile, outfile); err == nil { |