Permalink
Browse files

freeing worker queue right after

  • Loading branch information...
1 parent 3bbcbc8 commit d965d20931ab9f278b3804089b30a2eaf1333cae @pgte committed Oct 17, 2011
Showing with 5 additions and 2 deletions.
  1. +4 −1 lib/pipeline.js
  2. +1 −1 package.json
View
@@ -356,7 +356,10 @@ function Pipeline(name, options) {
// Forward
if (! queue) { throw new Error('You must configure this pipeline with a queue'); }
queue.pop(jobName(stateName), function(job, done) {
- workerForward(job, stateName, done);
+ done();
+ workerForward(job, stateName, function(err) {
+ if (err) { console.err(err); }
+ });
});
// Back
View
@@ -1,7 +1,7 @@
{ "name" : "banzai"
, "description" : "Library for creating document processing pipelines"
, "tags" : ["ETL", "pipeline", "document", "state machine"]
-, "version" : "0.5.1"
+, "version" : "0.5.2"
, "author" : "Pedro Teixeira <pedro.teixeira@gmail.com>"
, "repository" :
{ "type" : "git"

0 comments on commit d965d20

Please sign in to comment.