From 839ce95c37b35ce64410b8fa033c95ba439f2b51 Mon Sep 17 00:00:00 2001 From: Robin Olsen Date: Wed, 11 Mar 2026 11:24:34 +0100 Subject: [PATCH] wait for interface to close --- pkg/task/runner.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/pkg/task/runner.go b/pkg/task/runner.go index 3e25791..17597ef 100644 --- a/pkg/task/runner.go +++ b/pkg/task/runner.go @@ -110,6 +110,9 @@ func (r *TaskRunner) Run(ctx context.Context, t Tasker, i Interface, iType Inter close(stopChan) close(quitChan) collector.setCompleted(true) + if err := <-interfaceErr; err != nil { + return fmt.Errorf("task interface failed during shutdown: %w", err) + } case err := <-interfaceErr: close(stopChan)