Fixing issue Meteor-Community-Packages#731 and Meteor-Community-Packa…

…ges#408
louis49 · Jan 12, 2016 · a12d2b1 · a12d2b1
1 parent 593960c
commit a12d2b1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/packages/tempstore/tempStore.js b/packages/tempstore/tempStore.js
@@ -299,6 +299,8 @@ FS.TempStore.createWriteStream = function(fileObj, options) {
     // Progress
     self.emit('progress', fileObj, chunkNum, chunkCount, chunkSum, result);
 
+    fileObj.update({ $set: {node_id: process.env.METEOR_PARENT_PID} });
+
     // If upload is completed
     if (chunkCount === chunkSum) {
       // We no longer need the chunk info

diff --git a/packages/worker/fileWorker.js b/packages/worker/fileWorker.js
@@ -84,6 +84,7 @@ function getReadyQuery(storeName) {
   var selector = {uploadedAt: {$exists: true}};
   selector['copies.' + storeName] = null;
   selector['failures.copies.' + storeName + '.doneTrying'] = {$ne: true};
+  selector['node_id'] = process.env.METEOR_PARENT_PID;
   return selector;
 }