We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d01389d commit bd4146fCopy full SHA for bd4146f
1 file changed
internal/sinks/postgres.go
@@ -606,7 +606,12 @@ var migrations func() migrator.Option = func() migrator.Option {
606
&migrator.Migration{
607
Name: "01180 Apply admin functions migrations for v5",
608
Func: func(ctx context.Context, tx pgx.Tx) error {
609
- _, err := tx.Exec(ctx, `DROP FUNCTION IF EXISTS admin.ensure_partition_metric_dbname_time`)
+ _, err := tx.Exec(ctx, `
610
+ DROP FUNCTION IF EXISTS admin.ensure_partition_metric_dbname_time;
611
+ DROP FUNCTION IF EXISTS admin.ensure_partition_metric_time;
612
+ DROP FUNCTION IF EXISTS admin.get_old_time_partitions(integer, text);
613
+ DROP FUNCTION IF EXISTS admin.drop_old_time_partitions(integer, boolean, text);
614
+ `)
615
if err != nil {
616
return err
617
}
0 commit comments