Wait for log to finish

canonical · Oct 28, 2024 · 54c9815 · 54c9815
1 parent 5a05866
commit 54c9815
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/kine/logstructured/logstructured.go b/pkg/kine/logstructured/logstructured.go
@@ -70,6 +70,7 @@ func (l *LogStructured) Start(ctx context.Context) error {
 
 func (l *LogStructured) Wait() {
 	l.wg.Wait()
+	l.log.Wait()
 }
 
 func (l *LogStructured) Get(ctx context.Context, key, rangeEnd string, limit, revision int64) (revRet int64, kvRet *server.KeyValue, errRet error) {