defer transaction handling

pashagolub · web-flow · commit 44cbaaa3024b · 2025-07-31T12:21:37.000+02:00
diff --git a/internal/sinks/postgres.go b/internal/sinks/postgres.go
@@ -547,7 +547,7 @@ func (pgw *PostgresWriter) StartMaintenanceActivity(ctx context.Context, activit
 		logger.Errorf("Starting transaction for %s maintenance failed: %w", activity, err)
 		return false
 	}
-	func() {
+	defer func() {
 		if err != nil {
 			_ = tx.Rollback(pgw.ctx)
 		} else {

Original file line number	Diff line number	Diff line change
`@@ -547,7 +547,7 @@ func (pgw *PostgresWriter) StartMaintenanceActivity(ctx context.Context, activit`
`547`	`547`	`logger.Errorf("Starting transaction for %s maintenance failed: %w", activity, err)`
`548`	`548`	`return false`
`549`	`549`	`}`
`550`		`- func() {`
	`550`	`+ defer func() {`
`551`	`551`	`if err != nil {`
`552`	`552`	`_ = tx.Rollback(pgw.ctx)`
`553`	`553`	`} else {`