diff --git a/.changelog/12248.txt b/.changelog/12248.txt new file mode 100644 index 000000000000..5931f72d394b --- /dev/null +++ b/.changelog/12248.txt @@ -0,0 +1,3 @@ +```release-note:improvement +api: `AllocFS.Logs` now explicitly closes frames channel after being canceled +``` diff --git a/api/fs.go b/api/fs.go index e5340c9668ba..e0a8383e9fb3 100644 --- a/api/fs.go +++ b/api/fs.go @@ -257,6 +257,7 @@ func (a *AllocFS) Logs(alloc *Allocation, follow bool, task, logType, origin str // Check if we have been cancelled select { case <-cancel: + close(frames) return default: }