yield partial on context cancel

joshjennings98 · joshjennings98 · commit 8eeab36c221b · 2025-05-30T11:32:51.000+01:00
diff --git a/utils/logs/fifo_logger.go b/utils/logs/fifo_logger.go
@@ -49,6 +49,9 @@ func (w *FIFOWriter) ReadLines(ctx context.Context) iter.Seq[string] {
 		var partial []byte
 		for {
 			if err := parallelisation.DetermineContextError(ctx); err != nil {
+				if len(partial) > 0 {
+					yield(string(partial))
+				}
 				return
 			}
 

Original file line number	Diff line number	Diff line change
`@@ -49,6 +49,9 @@ func (w *FIFOWriter) ReadLines(ctx context.Context) iter.Seq[string] {`
`49`	`49`	`var partial []byte`
`50`	`50`	`for {`
`51`	`51`	`if err := parallelisation.DetermineContextError(ctx); err != nil {`
	`52`	`+ if len(partial) > 0 {`
	`53`	`+ yield(string(partial))`
	`54`	`+ }`
`52`	`55`	`return`
`53`	`56`	`}`
`54`	`57`