pg-boss - npm Package Compare versions

Comparing version 10.0.6 to 10.1.0

package.json

		{
		"name": "pg-boss",
		"version": "10.0.6",
		"version": "10.1.0",
		"description": "Queueing jobs in Postgres from Node.js like a boss",
		@@ -5,0 +5,0 @@ "main": "./src/index.js",

src/manager.js

		@@ -411,3 +411,5 @@ const assert = require('node:assert')

		return await db.executeSql(this.insertJobsCommand, params)
		const { rows } = await db.executeSql(this.insertJobsCommand, params)

		return (rows.length) ? rows.map(i => i.id) : null
		}
		@@ -414,0 +416,0 @@

src/plans.js

		@@ -731,2 +731,3 @@ const DEFAULT_SCHEMA = 'pgboss'
		singleton_key,
		singleton_on,
		dead_letter,
		@@ -747,2 +748,6 @@ expire_in,
		"singletonKey" as singleton_key,
		CASE
		WHEN "singletonSeconds" IS NOT NULL THEN 'epoch'::timestamp + '1 second'::interval * ("singletonSeconds" * floor( date_part('epoch', now()) / "singletonSeconds" ))
		ELSE NULL
		END as singleton_on,
		COALESCE("deadLetter", q.dead_letter) as dead_letter,
		@@ -783,3 +788,3 @@ CASE
		"singletonKey" text,
		"singletonOn" text,
		"singletonSeconds" integer,
		"expireInSeconds" integer,
		@@ -786,0 +791,0 @@ "keepUntil" timestamp with time zone,

src/timekeeper.js

		@@ -63,3 +63,3 @@ const EventEmitter = require('node:events')

		await this.manager.work(QUEUES.SEND_IT, options, (jobs) => this.manager.insert(jobs.map(i => i.data)))
		await this.manager.work(QUEUES.SEND_IT, options, async (jobs) => { await this.manager.insert(jobs.map(i => i.data)) })

		@@ -66,0 +66,0 @@ setImmediate(() => this.onCron())

types.d.ts

		@@ -210,2 +210,3 @@ import { EventEmitter } from 'events'
		singletonKey?: string;
		singletonSeconds?: number;
		expireInSeconds?: number;
		@@ -212,0 +213,0 @@ keepUntil?: Date \| string;

New alerts