fix scheduling debounce (#479)

.npmignore

@@ -5,4 +5,5 @@ docs
 test
 .editorconfig
 *.tgz
-coverage
+coverage
+examples

test/readme.js → examples/readme.js

@@ -1,5 +1,4 @@
-const helper = require('./testHelper')
-const { delay } = require('../src/tools')
+const helper = require('../test/testHelper')
 
 async function readme () {
   const PgBoss = require('../src')
@@ -20,9 +19,6 @@ async function readme () {
   await boss.work(queue, async ([job]) => {
     console.log(`received job ${job.id} with data ${JSON.stringify(job.data)}`)
   })
-
-  await delay(2000)
-  await boss.stop()
 }
 
 readme()

examples/schedule.js

@@ -0,0 +1,26 @@
+const helper = require('../test/testHelper')
+
+async function schedule () {
+  const PgBoss = require('../src')
+  const boss = new PgBoss(helper.getConnectionString())
+
+  boss.on('error', console.error)
+
+  await boss.start()
+
+  const queue = 'scheduled-queue'
+
+  await boss.createQueue(queue)
+
+  await boss.schedule(queue, '*/2 * * * *', { arg1: 'schedule me' })
+
+  await boss.work(queue, async ([job]) => {
+    console.log(`received job ${job.id} with data ${JSON.stringify(job.data)} on ${new Date().toISOString()}`)
+  })
+}
+
+schedule()
+  .catch(err => {
+    console.log(err)
+    process.exit(1)
+  })

package.json

@@ -1,6 +1,6 @@
 {
   "name": "pg-boss",
-  "version": "10.0.4",
+  "version": "10.0.5",
   "description": "Queueing jobs in Postgres from Node.js like a boss",
   "main": "./src/index.js",
   "engines": {

src/timekeeper.js

@@ -144,7 +144,7 @@ class Timekeeper extends EventEmitter {
     const scheduled = schedules
       .filter(i => this.shouldSendIt(i.cron, i.timezone))
       .map(({ name, data, options }) =>
-        ({ name: QUEUES.SEND_IT, data: { name, data, options }, options: { singletonKey: name, singletonSeconds: 60 } }))
+        ({ name: QUEUES.SEND_IT, data: { name, data, options }, singletonKey: name, singletonSeconds: 60 }))
 
     if (scheduled.length > 0 && !this.stopped) {
       await this.manager.insert(scheduled)