fix: Flush DeleteRecord messages when batch writer is flushed

maaarcelino · maaarcelino · commit d9536cb7984b · 2025-05-19T10:54:34.000+02:00
diff --git a/writers/batchwriter/batchwriter.go b/writers/batchwriter/batchwriter.go
@@ -107,7 +107,10 @@ func (w *BatchWriter) Flush(ctx context.Context) error {
 	if err := w.flushMigrateTables(ctx); err != nil {
 		return err
 	}
-	return w.flushDeleteStaleTables(ctx)
+	if err := w.flushDeleteStaleTables(ctx); err != nil {
+		return err
+	}
+	return w.flushDeleteRecordTables(ctx)
 }
 
 func (w *BatchWriter) Close(context.Context) error {

Original file line number	Diff line number	Diff line change
`@@ -107,7 +107,10 @@ func (w *BatchWriter) Flush(ctx context.Context) error {`
`107`	`107`	`if err := w.flushMigrateTables(ctx); err != nil {`
`108`	`108`	`return err`
`109`	`109`	`}`
`110`		`- return w.flushDeleteStaleTables(ctx)`
	`110`	`+ if err := w.flushDeleteStaleTables(ctx); err != nil {`
	`111`	`+ return err`
	`112`	`+ }`
	`113`	`+ return w.flushDeleteRecordTables(ctx)`
`111`	`114`	`}`
`112`	`115`
`113`	`116`	`func (w *BatchWriter) Close(context.Context) error {`