diff --git a/lib/node.io/processor.js b/lib/node.io/processor.js
index <HASH>..<HASH> 100644
--- a/lib/node.io/processor.js
+++ b/lib/node.io/processor.js
@@ -550,13 +550,13 @@ Processor.prototype.input = function(job, input, forWorker) {
 //Called when a job instance wants to dynamically add input (outside of job.input())
 Processor.prototype.addInput = function(job, add, dont_flatten) {
     var j = this.jobs[job];
-        
-    if (isWorker && !isMaster) {
+    
+    //if (isWorker && !isMaster) {
     
         //Send the added input back to the master so that it is evenly distributed among workers
-        master.send({type:'add',job:job,add:add,dont_flatten:dont_flatten});
+        //master.send({type:'add',job:job,add:add,dont_flatten:dont_flatten});
         
-    } else {
+    //} else {
         if (!dont_flatten && add instanceof Array) {
             add.forEach(function(line) {
                 j.input.push(line);
@@ -564,7 +564,7 @@ Processor.prototype.addInput = function(job, add, dont_flatten) {
         } else {
             j.input.push(add);
         }
-    }
+    //}
 }
 
 Processor.prototype.output = function(job, output) {
Temporarily reverted addInput