Merge branch 'main' into devhawk/dynamic-queues

Author: devhawk

transact/src/main/java/dev/dbos/transact/migrations/MigrationManager.java

@@ -675,16 +675,16 @@ created_at BIGINT NOT NULL DEFAULT (EXTRACT(epoch FROM now()) * 1000.0)::bigint
           timeout_ms BIGINT DEFAULT NULL,
           deadline_epoch_ms BIGINT DEFAULT NULL,
           deduplication_id TEXT DEFAULT NULL,
-          priority INTEGER DEFAULT NULL,
+          priority INT4 DEFAULT NULL,
           queue_partition_key TEXT DEFAULT NULL
       ) RETURNS TEXT AS $$
       DECLARE
           v_workflow_id TEXT;
           v_serialized_inputs TEXT;
           v_owner_xid TEXT;
           v_now BIGINT;
-          v_recovery_attempts INTEGER := 0;
-          v_priority INTEGER;
+          v_recovery_attempts INT4 := 0;
+          v_priority INT4;
       BEGIN
 
           -- Validate required parameters
@@ -799,7 +799,7 @@ static String migration20(boolean useListenNotify, boolean isCockroach) {
     var m =
         """
         ALTER FUNCTION "%1$s".enqueue_workflow(
-            TEXT, TEXT, JSON[], JSON, TEXT, TEXT, TEXT, TEXT, BIGINT, BIGINT, TEXT, INTEGER, TEXT
+            TEXT, TEXT, JSON[], JSON, TEXT, TEXT, TEXT, TEXT, BIGINT, BIGINT, TEXT, INT4, TEXT
         ) SET search_path = pg_catalog, pg_temp;
 
         ALTER FUNCTION "%1$s".send_message(