From fc8d8b37a113d93ad4533b21f69012f1000cda56 Mon Sep 17 00:00:00 2001 From: Gareth George Date: Fri, 22 Dec 2023 08:49:16 +0000 Subject: [PATCH] fix: task cancellation --- internal/orchestrator/scheduledtaskheap.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/orchestrator/scheduledtaskheap.go b/internal/orchestrator/scheduledtaskheap.go index 8854b24f..8fc6f34d 100644 --- a/internal/orchestrator/scheduledtaskheap.go +++ b/internal/orchestrator/scheduledtaskheap.go @@ -29,6 +29,7 @@ func (t *taskQueue) Push(tasks ...scheduledTask) { defer t.mu.Unlock() for _, task := range tasks { + task := task if task.task == nil { panic("task cannot be nil") }