From b4176ce3443567b16fef9f91c5a42a63d8d5e026 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Paul=20B=C3=BCtow?= <pbuetow@mimecast.com>
Date: Wed, 12 Feb 2020 16:09:18 +0000
Subject: separate context for each client in the scheduler

---
 internal/server/scheduler.go | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

(limited to 'internal/server')

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 {
-- 
cgit v1.2.3