tests

src/manager.js

@@ -252,10 +252,8 @@ class Manager extends EventEmitter {
     const jobs = result.rows.map(job => {
       job.done = async (error, response) => {
         if (error) {
-          console.log('job.done() got an error')
           await this.fail(job.id, error)
         } else {
-          console.log('job.done() reporting success')
           await this.complete(job.id, response)
         }
       }
@@ -267,7 +265,7 @@ class Manager extends EventEmitter {
         : jobs
   }
 
-  fetchCompleted (name, batchSize) {
+  async fetchCompleted (name, batchSize) {
     return this.fetch(completedJobPrefix + name, batchSize)
   }
 

test/databaseTest.js

@@ -86,10 +86,6 @@ describe('database', function () {
 
     const newConnections = connectionCount - prevConnectionCount
 
-    console.log(`listeners: ${listenerCount}  pool size: ${poolSize}`)
-    console.log('connections:')
-    console.log(`  before subscribing: ${prevConnectionCount}  now: ${connectionCount}  new: ${newConnections}`)
-
     assert(newConnections <= poolSize)
 
     await boss.stop()

test/initTest.js

@@ -2,15 +2,15 @@ const assert = require('chai').assert
 const PgBoss = require('../src/index')
 const helper = require('./testHelper')
 
-describe('initialization', function () {
+describe('init', function () {
   this.timeout(10000)
 
   beforeEach(() => helper.init())
 
   it('should fail if connecting to an uninitialized instance', async function () {
     try {
       const config = helper.getConfig()
-      new PgBoss(config).connect()
+      await new PgBoss(config).connect()
     } catch (error) {
       assert.isNotNull(error)
     }