timescale · svenklemm · Aug 29, 2023 · Aug 28, 2023
diff --git a/sql/cagg_migrate.sql b/sql/cagg_migrate.sql
@@ -122,21 +122,21 @@ BEGIN
         _interval_value := _integer_interval::TEXT;
         _interval_type  := _bucket_column_type;
         IF _bucket_column_type = 'bigint' THEN
-            _watermark := COALESCE(_timescaledb_internal.cagg_watermark(_cagg_data.mat_hypertable_id)::bigint, '-9223372036854775808'::bigint)::TEXT;
+            _watermark := COALESCE(_timescaledb_functions.cagg_watermark(_cagg_data.mat_hypertable_id)::bigint, '-9223372036854775808'::bigint)::TEXT;
         ELSIF _bucket_column_type = 'integer' THEN
-            _watermark := COALESCE(_timescaledb_internal.cagg_watermark(_cagg_data.mat_hypertable_id)::integer, '-2147483648'::integer)::TEXT;
+            _watermark := COALESCE(_timescaledb_functions.cagg_watermark(_cagg_data.mat_hypertable_id)::integer, '-2147483648'::integer)::TEXT;
         ELSE
-            _watermark := COALESCE(_timescaledb_internal.cagg_watermark(_cagg_data.mat_hypertable_id)::smallint, '-32768'::smallint)::TEXT;
+            _watermark := COALESCE(_timescaledb_functions.cagg_watermark(_cagg_data.mat_hypertable_id)::smallint, '-32768'::smallint)::TEXT;
         END IF;
     ELSE
         _interval_value := _time_interval::TEXT;
         _interval_type  := 'interval';
-        _watermark      := COALESCE(_timescaledb_functions.to_timestamp(_timescaledb_internal.cagg_watermark(_cagg_data.mat_hypertable_id)), '-infinity'::timestamptz)::TEXT;
+        _watermark      := COALESCE(_timescaledb_functions.to_timestamp(_timescaledb_functions.cagg_watermark(_cagg_data.mat_hypertable_id)), '-infinity'::timestamptz)::TEXT;
 
         IF _bucket_column_type = 'timestamp with timezone' THEN
-            _watermark := COALESCE(_timescaledb_functions.to_timestamp(_timescaledb_internal.cagg_watermark(_cagg_data.mat_hypertable_id)), '-infinity'::timestamptz)::TEXT;
+            _watermark := COALESCE(_timescaledb_functions.to_timestamp(_timescaledb_functions.cagg_watermark(_cagg_data.mat_hypertable_id)), '-infinity'::timestamptz)::TEXT;
         ELSE
-            _watermark := COALESCE(_timescaledb_functions.to_timestamp_without_timezone(_timescaledb_internal.cagg_watermark(_cagg_data.mat_hypertable_id)), '-infinity'::timestamp)::TEXT;
+            _watermark := COALESCE(_timescaledb_functions.to_timestamp_without_timezone(_timescaledb_functions.cagg_watermark(_cagg_data.mat_hypertable_id)), '-infinity'::timestamp)::TEXT;
         END IF;
     END IF;
 

diff --git a/sql/cagg_utils.sql b/sql/cagg_utils.sql
@@ -7,7 +7,7 @@
 -- mat_hypertable_id - The hypertable ID of the CAGG materialized hypertable in the Access Node
 -- start_time - The starting time of the materialization invalidation log entry
 -- end_time - The ending time of the materialization invalidation log entry
-CREATE OR REPLACE FUNCTION _timescaledb_internal.invalidation_cagg_log_add_entry(
+CREATE OR REPLACE FUNCTION _timescaledb_functions.invalidation_cagg_log_add_entry(
     mat_hypertable_id INTEGER,
     start_time BIGINT,
     end_time BIGINT
@@ -18,19 +18,19 @@ CREATE OR REPLACE FUNCTION _timescaledb_internal.invalidation_cagg_log_add_entry
 -- raw_hypertable_id - The hypertable ID of the original distributed hypertable in the Access Node
 -- start_time - The starting time of the materialization invalidation log entry
 -- end_time - The ending time of the materialization invalidation log entry
-CREATE OR REPLACE FUNCTION _timescaledb_internal.invalidation_hyper_log_add_entry(
+CREATE OR REPLACE FUNCTION _timescaledb_functions.invalidation_hyper_log_add_entry(
     raw_hypertable_id INTEGER,
     start_time BIGINT,
     end_time BIGINT
 ) RETURNS VOID AS '@MODULE_PATHNAME@', 'ts_invalidation_hyper_log_add_entry' LANGUAGE C STRICT VOLATILE;
 
 -- raw_hypertable_id - The hypertable ID of the original distributed hypertable in the Access Node
-CREATE OR REPLACE FUNCTION _timescaledb_internal.hypertable_invalidation_log_delete(
+CREATE OR REPLACE FUNCTION _timescaledb_functions.hypertable_invalidation_log_delete(
     raw_hypertable_id INTEGER
 ) RETURNS VOID AS '@MODULE_PATHNAME@', 'ts_hypertable_invalidation_log_delete' LANGUAGE C STRICT VOLATILE;
 
 -- mat_hypertable_id - The hypertable ID of the CAGG materialized hypertable in the Access Node
-CREATE OR REPLACE FUNCTION _timescaledb_internal.materialization_invalidation_log_delete(
+CREATE OR REPLACE FUNCTION _timescaledb_functions.materialization_invalidation_log_delete(
     mat_hypertable_id INTEGER
 ) RETURNS VOID AS '@MODULE_PATHNAME@', 'ts_materialization_invalidation_log_delete' LANGUAGE C STRICT VOLATILE;
 
@@ -54,7 +54,7 @@ CREATE OR REPLACE FUNCTION _timescaledb_functions.drop_dist_ht_invalidation_trig
 -- max_bucket_widths - (Deprecated) This argument is ignored and is present only
 --                     for backward compatibility.
 -- bucket_functions - (Optional) The array of serialized information about bucket functions
-CREATE OR REPLACE FUNCTION _timescaledb_internal.invalidation_process_hypertable_log(
+CREATE OR REPLACE FUNCTION _timescaledb_functions.invalidation_process_hypertable_log(
     mat_hypertable_id INTEGER,
     raw_hypertable_id INTEGER,
     dimtype REGTYPE,
@@ -63,7 +63,7 @@ CREATE OR REPLACE FUNCTION _timescaledb_internal.invalidation_process_hypertable
     max_bucket_widths BIGINT[]
 ) RETURNS VOID AS '@MODULE_PATHNAME@', 'ts_invalidation_process_hypertable_log' LANGUAGE C STRICT VOLATILE;
 
-CREATE OR REPLACE FUNCTION _timescaledb_internal.invalidation_process_hypertable_log(
+CREATE OR REPLACE FUNCTION _timescaledb_functions.invalidation_process_hypertable_log(
     mat_hypertable_id INTEGER,
     raw_hypertable_id INTEGER,
     dimtype REGTYPE,
@@ -94,7 +94,7 @@ CREATE OR REPLACE FUNCTION _timescaledb_internal.invalidation_process_hypertable
 -- Returns a tuple of:
 -- ret_window_start - The merged refresh window starting time
 -- ret_window_end - The merged refresh window ending time
-CREATE OR REPLACE FUNCTION _timescaledb_internal.invalidation_process_cagg_log(
+CREATE OR REPLACE FUNCTION _timescaledb_functions.invalidation_process_cagg_log(
     mat_hypertable_id INTEGER,
     raw_hypertable_id INTEGER,
     dimtype REGTYPE,
@@ -107,7 +107,7 @@ CREATE OR REPLACE FUNCTION _timescaledb_internal.invalidation_process_cagg_log(
     OUT ret_window_end BIGINT
 ) RETURNS RECORD AS '@MODULE_PATHNAME@', 'ts_invalidation_process_cagg_log' LANGUAGE C STRICT VOLATILE;
 
-CREATE OR REPLACE FUNCTION _timescaledb_internal.invalidation_process_cagg_log(
+CREATE OR REPLACE FUNCTION _timescaledb_functions.invalidation_process_cagg_log(
     mat_hypertable_id INTEGER,
     raw_hypertable_id INTEGER,
     dimtype REGTYPE,

diff --git a/sql/updates/latest-dev.sql b/sql/updates/latest-dev.sql
@@ -116,11 +116,15 @@ DECLARE
     policy_refresh_continuous_aggregate_check,policy_refresh_continuous_aggregate,
     policy_reorder_check,policy_reorder,policy_retention_check,policy_retention,
 
+    cagg_watermark, cagg_watermark_materialized,
     cagg_migrate_plan_exists, cagg_migrate_pre_validation, cagg_migrate_create_plan, cagg_migrate_execute_create_new_cagg,
     cagg_migrate_execute_disable_policies, cagg_migrate_execute_enable_policies, cagg_migrate_execute_copy_policies,
     cagg_migrate_execute_refresh_new_cagg, cagg_migrate_execute_copy_data, cagg_migrate_execute_override_cagg,
     cagg_migrate_execute_drop_old_cagg, cagg_migrate_execute_plan,
 
+    hypertable_invalidation_log_delete, invalidation_cagg_log_add_entry, invalidation_hyper_log_add_entry,
+    invalidation_process_cagg_log, invalidation_process_hypertable_log, materialization_invalidation_log_delete,
+
     alter_job_set_hypertable_id
   }';
 BEGIN

diff --git a/sql/updates/post-update.sql b/sql/updates/post-update.sql
@@ -185,7 +185,7 @@ BEGIN
     SELECT extversion INTO ts_version FROM pg_extension WHERE extname = 'timescaledb';
     IF ts_version >= '2.11.0' THEN
       INSERT INTO _timescaledb_catalog.continuous_aggs_watermark (mat_hypertable_id, watermark)
-      SELECT a.mat_hypertable_id, _timescaledb_internal.cagg_watermark_materialized(a.mat_hypertable_id)
+      SELECT a.mat_hypertable_id, _timescaledb_functions.cagg_watermark_materialized(a.mat_hypertable_id)
       FROM _timescaledb_catalog.continuous_agg a
       LEFT JOIN _timescaledb_catalog.continuous_aggs_watermark b ON b.mat_hypertable_id = a.mat_hypertable_id
       WHERE b.mat_hypertable_id IS NULL

diff --git a/sql/updates/reverse-dev.sql b/sql/updates/reverse-dev.sql
@@ -127,3 +127,14 @@ ALTER FUNCTION _timescaledb_functions.stop_background_workers() SET SCHEMA _time
 ALTER FUNCTION _timescaledb_functions.restart_background_workers() SET SCHEMA _timescaledb_internal;
 ALTER FUNCTION _timescaledb_functions.alter_job_set_hypertable_id(integer,regclass) SET SCHEMA _timescaledb_internal;
 
+ALTER FUNCTION _timescaledb_functions.cagg_watermark(integer) SET SCHEMA _timescaledb_internal;
+ALTER FUNCTION _timescaledb_functions.cagg_watermark_materialized(integer) SET SCHEMA _timescaledb_internal;
+ALTER FUNCTION _timescaledb_functions.hypertable_invalidation_log_delete(integer) SET SCHEMA _timescaledb_internal;
+ALTER FUNCTION _timescaledb_functions.invalidation_cagg_log_add_entry(integer,bigint,bigint) SET SCHEMA _timescaledb_internal;
+ALTER FUNCTION _timescaledb_functions.invalidation_hyper_log_add_entry(integer,bigint,bigint) SET SCHEMA _timescaledb_internal;
+ALTER FUNCTION _timescaledb_functions.invalidation_process_cagg_log(integer,integer,regtype,bigint,bigint,integer[],bigint[],bigint[]) SET SCHEMA _timescaledb_internal;
+ALTER FUNCTION _timescaledb_functions.invalidation_process_cagg_log(integer,integer,regtype,bigint,bigint,integer[],bigint[],bigint[],text[]) SET SCHEMA _timescaledb_internal;
+ALTER FUNCTION _timescaledb_functions.invalidation_process_hypertable_log(integer,integer,regtype,integer[],bigint[],bigint[]) SET SCHEMA _timescaledb_internal;
+ALTER FUNCTION _timescaledb_functions.invalidation_process_hypertable_log(integer,integer,regtype,integer[],bigint[],bigint[],text[]) SET SCHEMA _timescaledb_internal;
+ALTER FUNCTION _timescaledb_functions.materialization_invalidation_log_delete(integer) SET SCHEMA _timescaledb_internal;
+
diff --git a/sql/util_time.sql b/sql/util_time.sql
@@ -38,10 +38,10 @@ $BODY$ SET search_path TO pg_catalog, pg_temp;
 CREATE OR REPLACE FUNCTION _timescaledb_functions.time_to_internal(time_val ANYELEMENT)
 RETURNS BIGINT AS '@MODULE_PATHNAME@', 'ts_time_to_internal' LANGUAGE C VOLATILE STRICT;
 
-CREATE OR REPLACE FUNCTION _timescaledb_internal.cagg_watermark(hypertable_id INTEGER)
+CREATE OR REPLACE FUNCTION _timescaledb_functions.cagg_watermark(hypertable_id INTEGER)
 RETURNS INT8 AS '@MODULE_PATHNAME@', 'ts_continuous_agg_watermark' LANGUAGE C STABLE STRICT PARALLEL RESTRICTED;
 
-CREATE OR REPLACE FUNCTION _timescaledb_internal.cagg_watermark_materialized(hypertable_id INTEGER)
+CREATE OR REPLACE FUNCTION _timescaledb_functions.cagg_watermark_materialized(hypertable_id INTEGER)
 RETURNS INT8 AS '@MODULE_PATHNAME@', 'ts_continuous_agg_watermark_materialized' LANGUAGE C STABLE STRICT PARALLEL SAFE;
 
 CREATE OR REPLACE FUNCTION _timescaledb_functions.subtract_integer_from_now( hypertable_relid REGCLASS, lag INT8 )

diff --git a/test/expected/license.out b/test/expected/license.out
@@ -79,10 +79,10 @@ GROUP BY bucket;
 CALL refresh_continuous_aggregate('metrics_hourly', NULL, NULL);
 ERROR:  function "refresh_continuous_aggregate" is not supported under the current "apache" license
 HINT:  Upgrade your license to 'timescale' to use this free community feature.
-SELECT _timescaledb_internal.invalidation_hyper_log_add_entry(0, 0, 0);
+SELECT _timescaledb_functions.invalidation_hyper_log_add_entry(0, 0, 0);
 ERROR:  function "invalidation_hyper_log_add_entry" is not supported under the current "apache" license
 HINT:  Upgrade your license to 'timescale' to use this free community feature.
-SELECT _timescaledb_internal.invalidation_cagg_log_add_entry(0, 0, 0);
+SELECT _timescaledb_functions.invalidation_cagg_log_add_entry(0, 0, 0);
 ERROR:  function "invalidation_cagg_log_add_entry" is not supported under the current "apache" license
 HINT:  Upgrade your license to 'timescale' to use this free community feature.
 DROP MATERIALIZED VIEW metrics_hourly;

diff --git a/test/sql/license.sql b/test/sql/license.sql
@@ -60,8 +60,8 @@ GROUP BY bucket;
 
 CALL refresh_continuous_aggregate('metrics_hourly', NULL, NULL);
 
-SELECT _timescaledb_internal.invalidation_hyper_log_add_entry(0, 0, 0);
-SELECT _timescaledb_internal.invalidation_cagg_log_add_entry(0, 0, 0);
+SELECT _timescaledb_functions.invalidation_hyper_log_add_entry(0, 0, 0);
+SELECT _timescaledb_functions.invalidation_cagg_log_add_entry(0, 0, 0);
 
 DROP MATERIALIZED VIEW metrics_hourly;
 DROP TABLE metrics;

diff --git a/tsl/src/continuous_aggs/common.c b/tsl/src/continuous_aggs/common.c
@@ -118,7 +118,7 @@ RemoveRangeTableEntries(Query *query)
  *                  UNION ALL
  *                  SELECT * from q2 where existing_qual and <coale_qual>
  * where coale_qual is: time < ----> (or >= )
- * COALESCE(_timescaledb_functions.to_timestamp(_timescaledb_internal.cagg_watermark( <htid>)),
+ * COALESCE(_timescaledb_functions.to_timestamp(_timescaledb_functions.cagg_watermark( <htid>)),
  * '-infinity'::timestamp with time zone)
  * The WHERE clause of the final view is removed.
  */
@@ -1130,7 +1130,7 @@ build_boundary_call(int32 ht_id, Oid type)
 	FuncExpr *boundary;
 
 	Oid boundary_func_oid =
-		LookupFuncName(list_make2(makeString(INTERNAL_SCHEMA_NAME), makeString(BOUNDARY_FUNCTION)),
+		LookupFuncName(list_make2(makeString(FUNCTIONS_SCHEMA_NAME), makeString(BOUNDARY_FUNCTION)),
 					   lengthof(argtyp),
 					   argtyp,
 					   false);
@@ -1220,7 +1220,7 @@ makeRangeTblEntry(Query *query, const char *aliasname)
  *                  UNION ALL
  *                  SELECT * from q2 where existing_qual and <coale_qual>
  * where coale_qual is: time < ----> (or >= )
- * COALESCE(_timescaledb_functions.to_timestamp(_timescaledb_internal.cagg_watermark( <htid>)),
+ * COALESCE(_timescaledb_functions.to_timestamp(_timescaledb_functions.cagg_watermark( <htid>)),
  * '-infinity'::timestamp with time zone)
  * See build_union_quals for COALESCE clauses.
  */

diff --git a/tsl/src/continuous_aggs/invalidation.c b/tsl/src/continuous_aggs/invalidation.c
@@ -283,7 +283,7 @@ remote_invalidation_log_add_entry(const Hypertable *raw_ht,
 	Assert(HypertableIsMaterialization == caggstatus || HypertableIsRawTable == caggstatus);
 
 	static const Oid type_id[INVALIDATION_CAGG_ADD_ENTRY_NARGS] = { INT4OID, INT8OID, INT8OID };
-	List *const fqn = list_make2(makeString(INTERNAL_SCHEMA_NAME),
+	List *const fqn = list_make2(makeString(FUNCTIONS_SCHEMA_NAME),
 								 makeString((caggstatus == HypertableIsMaterialization) ?
 												INVALIDATION_CAGG_LOG_ADD_ENTRY_FUNCNAME :
 												INVALIDATION_HYPER_LOG_ADD_ENTRY_FUNCNAME));
@@ -1221,7 +1221,7 @@ remote_invalidation_process_hypertable_log(int32 mat_hypertable_id, int32 raw_hy
 	static const Oid type_id[INVALIDATION_PROCESS_HYPERTABLE_LOG_NARGS] = {
 		INT4OID, INT4OID, REGTYPEOID, INT4ARRAYOID, INT8ARRAYOID, INT8ARRAYOID, TEXTARRAYOID
 	};
-	List *const fqn = list_make2(makeString(INTERNAL_SCHEMA_NAME),
+	List *const fqn = list_make2(makeString(FUNCTIONS_SCHEMA_NAME),
 								 makeString(INVALIDATION_PROCESS_HYPERTABLE_LOG_FUNCNAME));
 
 	/*
@@ -1432,7 +1432,7 @@ remote_invalidation_process_cagg_log(int32 mat_hypertable_id, int32 raw_hypertab
 		INT4OID,	  INT4OID,		REGTYPEOID,	  INT8OID,		INT8OID,
 		INT4ARRAYOID, INT8ARRAYOID, INT8ARRAYOID, TEXTARRAYOID,
 	};
-	List *const fqn = list_make2(makeString(INTERNAL_SCHEMA_NAME),
+	List *const fqn = list_make2(makeString(FUNCTIONS_SCHEMA_NAME),
 								 makeString(INVALIDATION_PROCESS_CAGG_LOG_FUNCNAME));
 
 	/*
@@ -1542,7 +1542,7 @@ remote_invalidation_log_delete(int32 raw_hypertable_id, ContinuousAggHypertableS
 	Assert(HypertableIsMaterialization == caggstatus || HypertableIsRawTable == caggstatus);
 
 	static const Oid type_id[INVALIDATION_LOG_DELETE_NARGS] = { INT4OID };
-	List *const fqn = list_make2(makeString(INTERNAL_SCHEMA_NAME),
+	List *const fqn = list_make2(makeString(FUNCTIONS_SCHEMA_NAME),
 								 makeString((caggstatus == HypertableIsMaterialization) ?
 												MATERIALIZATION_INVALIDATION_LOG_DELETE_FUNCNAME :
 												HYPERTABLE_INVALIDATION_LOG_DELETE_FUNCNAME));

diff --git a/tsl/test/expected/cagg_invalidation.out b/tsl/test/expected/cagg_invalidation.out
@@ -790,7 +790,7 @@ WHERE user_view_name = 'cond_1' \gset
 \if :IS_DISTRIBUTED
 \else
 \set ON_ERROR_STOP 0
-SELECT _timescaledb_internal.invalidation_cagg_log_add_entry(:cond_1_id, 1, 0);
+SELECT _timescaledb_functions.invalidation_cagg_log_add_entry(:cond_1_id, 1, 0);
 psql:include/cagg_invalidation_common.sql:456: ERROR:  cannot invalidate cagg, end time should be greater than start time
 \set ON_ERROR_STOP 1
 \endif
@@ -1004,7 +1004,7 @@ ORDER BY 1,2;
 \if :IS_DISTRIBUTED
 \else
 \set ON_ERROR_STOP 0
-SELECT _timescaledb_internal.invalidation_hyper_log_add_entry(:thresh_hyper_id, 1, 0);
+SELECT _timescaledb_functions.invalidation_hyper_log_add_entry(:thresh_hyper_id, 1, 0);
 psql:include/cagg_invalidation_common.sql:592: ERROR:  cannot invalidate hypertable, end time should be greater than start time
 \set ON_ERROR_STOP 1
 \endif

diff --git a/tsl/test/expected/cagg_invalidation_dist_ht-13.out b/tsl/test/expected/cagg_invalidation_dist_ht-13.out
@@ -853,7 +853,7 @@ WHERE user_view_name = 'cond_1' \gset
 \if :IS_DISTRIBUTED
 \else
 \set ON_ERROR_STOP 0
-SELECT _timescaledb_internal.invalidation_cagg_log_add_entry(:cond_1_id, 1, 0);
+SELECT _timescaledb_functions.invalidation_cagg_log_add_entry(:cond_1_id, 1, 0);
 \set ON_ERROR_STOP 1
 \endif
 -- Test invalidations with bucket size 1
@@ -1067,7 +1067,7 @@ ORDER BY 1,2;
 \if :IS_DISTRIBUTED
 \else
 \set ON_ERROR_STOP 0
-SELECT _timescaledb_internal.invalidation_hyper_log_add_entry(:thresh_hyper_id, 1, 0);
+SELECT _timescaledb_functions.invalidation_hyper_log_add_entry(:thresh_hyper_id, 1, 0);
 \set ON_ERROR_STOP 1
 \endif
 -- Test that threshold is initilized to min value when there's no data

diff --git a/tsl/test/expected/cagg_invalidation_dist_ht-14.out b/tsl/test/expected/cagg_invalidation_dist_ht-14.out
@@ -853,7 +853,7 @@ WHERE user_view_name = 'cond_1' \gset
 \if :IS_DISTRIBUTED
 \else
 \set ON_ERROR_STOP 0
-SELECT _timescaledb_internal.invalidation_cagg_log_add_entry(:cond_1_id, 1, 0);
+SELECT _timescaledb_functions.invalidation_cagg_log_add_entry(:cond_1_id, 1, 0);
 \set ON_ERROR_STOP 1
 \endif
 -- Test invalidations with bucket size 1
@@ -1067,7 +1067,7 @@ ORDER BY 1,2;
 \if :IS_DISTRIBUTED
 \else
 \set ON_ERROR_STOP 0
-SELECT _timescaledb_internal.invalidation_hyper_log_add_entry(:thresh_hyper_id, 1, 0);
+SELECT _timescaledb_functions.invalidation_hyper_log_add_entry(:thresh_hyper_id, 1, 0);
 \set ON_ERROR_STOP 1
 \endif
 -- Test that threshold is initilized to min value when there's no data

diff --git a/tsl/test/expected/cagg_invalidation_dist_ht-15.out b/tsl/test/expected/cagg_invalidation_dist_ht-15.out
@@ -853,7 +853,7 @@ WHERE user_view_name = 'cond_1' \gset
 \if :IS_DISTRIBUTED
 \else
 \set ON_ERROR_STOP 0
-SELECT _timescaledb_internal.invalidation_cagg_log_add_entry(:cond_1_id, 1, 0);
+SELECT _timescaledb_functions.invalidation_cagg_log_add_entry(:cond_1_id, 1, 0);
 \set ON_ERROR_STOP 1
 \endif
 -- Test invalidations with bucket size 1
@@ -1067,7 +1067,7 @@ ORDER BY 1,2;
 \if :IS_DISTRIBUTED
 \else
 \set ON_ERROR_STOP 0
-SELECT _timescaledb_internal.invalidation_hyper_log_add_entry(:thresh_hyper_id, 1, 0);
+SELECT _timescaledb_functions.invalidation_hyper_log_add_entry(:thresh_hyper_id, 1, 0);
 \set ON_ERROR_STOP 1
 \endif
 -- Test that threshold is initilized to min value when there's no data