Fix async_op test regarding stop() behavior

Signed-off-by: Daniel Sabsay <[email protected]>
thanos-io · Jan 7, 2025 · 8f9b5f5 · 8f9b5f5
1 parent ffd4f9c
commit 8f9b5f5
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/pkg/cacheutil/async_op.go b/pkg/cacheutil/async_op.go
@@ -54,7 +54,14 @@ func (p *AsyncOperationProcessor) asyncQueueProcessLoop() {
 		case op := <-p.asyncQueue:
 			op()
 		case <-p.stop:
-			return
+			// Run all remaining operations before stopping
+			select {
+			case op := <-p.asyncQueue:
+				op()
+				continue
+			default:
+				return
+			}
 		}
 	}
 }