assets store registry of its apis is now available for worker and sli…

…cer resolves #583 (#585)
terascope · Oct 10, 2017 · efbdb5f · efbdb5f
1 parent aa06747
commit efbdb5f
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/lib/cluster/slicer.js b/lib/cluster/slicer.js
@@ -331,7 +331,11 @@ module.exports = function(context) {
         messaging.send({message: 'job:error:terminal', error: errMsg, ex_id: ex_id})
     }
     else {
-        Promise.resolve(job_runner.initialize(events, logger))
+        Promise.resolve(require('./storage/assets')(context))
+            .then(function(assets_store) {
+                // assets store is loaded so it can register under context.apis
+                return job_runner.initialize(events, logger);
+            })
             .then(function(_job) {
                 job = _job;
                 slicer = _job.slicer;

diff --git a/lib/cluster/worker.js b/lib/cluster/worker.js
@@ -105,7 +105,11 @@ module.exports = function(context) {
     messaging.register('process:SIGTERM', noOP);
     messaging.register('process:SIGINT', noOP);
 
-    Promise.resolve(job_runner.initialize(events, logger))
+    Promise.resolve(require('./storage/assets')(context))
+        .then(function(assets_store) {
+            // assets store is loaded so it can register under context.apis
+            return job_runner.initialize(events, logger);
+        })
         .then(function(_job) {
             job = _job;
             queue = _job.queue;