Version 4

Author: fabriziomello

sql/updates/reverse-dev.sql

@@ -86,6 +86,3 @@ FROM _timescaledb_catalog.continuous_agg, LATERAL _timescaledb_functions.cagg_ge
 SELECT pg_catalog.pg_extension_config_dump('_timescaledb_catalog.continuous_aggs_bucket_function', '');
 
 GRANT SELECT ON _timescaledb_catalog.continuous_aggs_bucket_function TO PUBLIC;
-
-DROP FUNCTION IF EXISTS _timescaledb_functions.cagg_get_bucket_function_info(INTEGER);
-

tsl/src/continuous_aggs/utils.c

@@ -596,7 +596,7 @@ continuous_agg_migrate_to_time_bucket(PG_FUNCTION_ARGS)
 	/* Update the time_bucket_fuction */
 	cagg->bucket_function->bucket_function = new_bucket_function;
 	bool origin_added_during_migration = false;
-	TimestampTz bucket_time_origin_to_replace = 0;
+	TimestampTz bucket_time_origin_to_replace = cagg->bucket_function->bucket_time_origin;
 
 	/* Set new origin if not already present in the function definition. This is needed since
 	 * time_bucket and time_bucket_ng use different origin default values.
@@ -615,6 +615,8 @@ continuous_agg_migrate_to_time_bucket(PG_FUNCTION_ARGS)
 									bucket_time_origin_to_replace,
 									need_parameter_order_change);
 
+	CommandCounterIncrement();
+
 	/* Fetch new CAgg definition from catalog */
 	ContinuousAgg PG_USED_FOR_ASSERTS_ONLY *new_cagg_definition =
 		cagg_get_by_relid_or_fail(cagg_relid);

tsl/test/expected/cagg_bgw-17.out

@@ -109,7 +109,7 @@ SELECT mat_hypertable_id, user_view_schema, user_view_name FROM _timescaledb_cat
                  2 | public           | test_continuous_agg_view
 (1 row)
 
-SELECT mat_hypertable_id, bucket_width FROM _timescaledb_catalog.continuous_aggs_bucket_function;
+SELECT mat_hypertable_id, bucket_width FROM _timescaledb_catalog.continuous_agg, LATERAL _timescaledb_functions.cagg_get_bucket_function_info(mat_hypertable_id);
  mat_hypertable_id | bucket_width 
 -------------------+--------------
                  2 | 2