rethinkdb-job-queue - npm Package Compare versions

Comparing version 0.0.6 to 0.0.7

CHANGELOG.md

 # `rethinkdb-job-queue` Change log
 
+## v0.0.7 / 2016-08
+
+*   Fixed next() calls.
+*   Minor refactor.
+*   README updated.
+
 ## v0.0.6 / 2016-08-23
@@ -4,0 +10,0 @@

dist/job-completed.js

@@ -10,4 +10,4 @@ 'use strict';
 
-module.exports = function completed(job, data) {
-  logger('completed:  [' + job.id + ']');
+module.exports = function completed(job, result) {
+  logger('completed:  [' + job.id + ']', result);
   job.status = enums.status.completed;
@@ -21,3 +21,3 @@ job.dateFinished = moment().toDate();
   log.duration = duration;
-  log.data = data;
+  log.data = result;
   log.retryCount = job.retryCount;
@@ -24,0 +24,0 @@

dist/job-failed.js

@@ -10,3 +10,3 @@ 'use strict';
 
-module.exports = function failed(err, job) {
+module.exports = function failed(job, err) {
   logger('failed:  [' + job.id + ']');
@@ -13,0 +13,0 @@ logger('error', err);

dist/queue-process.js

@@ -72,3 +72,3 @@ 'use strict';
       } else if (err) {
-        return jobFailed(err, job);
+        return jobFailed(job, err);
       }
@@ -75,0 +75,0 @@ }).then(function (finalResult) {

package.json

 {
   "name": "rethinkdb-job-queue",
-  "version": "0.0.6",
+  "version": "0.0.7",
   "description": "A persistent job or task queue backed by RethinkDB.",
@@ -5,0 +5,0 @@ "main": "index.js",

README.md

@@ -19,9 +19,12 @@ # Introduction
 
-__Warning:__ This is early days for `rethinkdb-job-queue`. The API may change.
+For full documentation [please see the wiki][rjq-wiki-url]
 
-__Note:__ Documentation is mostly complete.
+## Project Status
 
-There are over 1100 integration tests and it is fully functional.
+*   This `rethinkdb-job-queue` module is fully functional.
+*   There are over 1100 integration tests.
+*   This project is complete and needs to be taken out for a spin.
+*   In a few months I will bump the version up to 1.0.0 to support [SemVer](http://semver.org/).
+*   Please provide feedback or raise issues prior to the version bump.
 
-For full documentation of the `rethinkdb-job-queue` package, [please see the wiki][rjq-wiki-url]
 
@@ -28,0 +31,0 @@ ## Quick Start

tests/job-failed.spec.js

@@ -65,3 +65,3 @@ const test = require('tape')
         t.comment('job-failed: Original Job Failure')
-        return jobFailed(err, savedJob[0])
+        return jobFailed(savedJob[0], err)
       }).then((retry1id) => {
@@ -89,3 +89,3 @@ t.equal(retry1id.length, 1, 'Job failed successfully')
         t.comment('job-failed: First Retry Job Failure')
-        return jobFailed(err, retry1[0])
+        return jobFailed(retry1[0], err)
       }).then((retry2id) => {
@@ -112,3 +112,3 @@ t.equal(retry2id.length, 1, 'Job failed successfully')
         t.comment('job-failed: Second Retry Job Failure')
-        return jobFailed(err, retry2[0])
+        return jobFailed(retry2[0], err)
       }).then((retry3id) => {
@@ -136,3 +136,3 @@ t.equal(retry3id.length, 1, 'Job failed successfully')
         t.comment('job-failed: Third and Final Retry Job Failure')
-        return jobFailed(err, retry3[0])
+        return jobFailed(retry3[0], err)
       }).then((failedId) => {
@@ -167,3 +167,3 @@ t.equal(failedId.length, 1, 'Job failed successfully')
         t.equal(savedJob[0].id, job.id, 'Job saved successfully')
-        return jobFailed(err, savedJob[0])
+        return jobFailed(savedJob[0], err)
       }).then((removeResult) => {
@@ -170,0 +170,0 @@ t.equal(removeResult.length, 1, 'Job failed successfully')

tests/queue-change.spec.js

@@ -101,3 +101,3 @@ const test = require('tape')
             t.equal(j.id, job.id, `Job Processed [${j.id}]`)
-            next(null, 'queue-change')
+            next('queue-change')
           }, processDelay)
@@ -104,0 +104,0 @@ return j.setProgress(50)

tests/queue.spec.js

@@ -27,3 +27,3 @@ const test = require('tape')
         setTimeout(function finishJob () {
-          next(null, `Job completed [${job.id}]`)
+          next(`Job completed [${job.id}]`)
         }, 100)
@@ -30,0 +30,0 @@ }

WORKLOG.md

@@ -12,3 +12,1 @@ # WORKLOG
 Add error documentation.
-
-Job parsing errors have a custom property err.dbError.

No alert changes

Improved metrics

Total package byte prevSize

227700

increased by0.07%

Number of lines in readme file

199

increased by1.53%

No dependency changes