diff --git a/pkg/workceptor/kubernetes.go b/pkg/workceptor/kubernetes.go
index 14d277b0d..14c279139 100644
--- a/pkg/workceptor/kubernetes.go
+++ b/pkg/workceptor/kubernetes.go
@@ -239,6 +239,14 @@ func (kw *kubeUnit) kubeLoggingWithReconnect(streamWait *sync.WaitGroup, stdout
 		for *stdinErr == nil { // check between every line read to see if we need to stop reading
 			line, err := streamReader.ReadString('\n')
 			if err != nil {
+				if kw.ctx.Err() == context.Canceled {
+					kw.Info(
+						"Context was canceled while reading logs for pod %s/%s. Assuming pod has finished",
+						podNamespace,
+						podName)
+
+					return
+				}
 				kw.Info(
 					"Detected Error: %s for pod %s/%s. Will retry %d more times.",
 					err,