steveo - npm Package Compare versions

Comparing version 1.0.27 to 1.0.28

lib/runner.js

@@ -17,3 +17,3 @@ 'use strict';
 
-var maxRss = process.env.STEVEO_MAX_RSS && parseInt(process.env.STEVEO_MAX_RSS);
+var maxRss = process.env.STEVEO_MAX_RSS && parseInt(process.env.STEVEO_MAX_RSS, 10);
 
@@ -47,3 +47,3 @@ var Runner = function Runner(config, registry, logger) {
               if (_iteratorNormalCompletion = (_step = _iterator.next()).done) {
-                _context.next = 33;
+                _context.next = 32;
                 break;
@@ -63,3 +63,3 @@ }
                 }
-              };
+              }
               // commit offset
@@ -70,6 +70,6 @@ params = JSON.parse(m.message.value.toString('utf8'));
               logger.info('Commit offset', topic, params);
-              _context.next = 18;
+              _context.next = 17;
               return consumer.commitOffset({ topic: topic, partition: partition, offset: m.offset, metadata: 'optional' });
 
-            case 18:
+            case 17:
               // eslint-disable-line
@@ -79,14 +79,14 @@ task = registry.getTask(topic);
               logger.info('Start subscribe', topic, params);
-              _context.next = 22;
+              _context.next = 21;
               return task.subscribe(params);
 
-            case 22:
+            case 21:
               // eslint-disable-line
               logger.info('Finish subscribe', topic, params);
               registry.events.emit('runner_complete', topic, params);
-              _context.next = 30;
+              _context.next = 29;
               break;
 
-            case 26:
-              _context.prev = 26;
+            case 25:
+              _context.prev = 25;
               _context.t0 = _context['catch'](9);
@@ -97,3 +97,3 @@
 
-            case 30:
+            case 29:
               _iteratorNormalCompletion = true;
@@ -103,8 +103,8 @@ _context.next = 5;
 
-            case 33:
-              _context.next = 39;
+            case 32:
+              _context.next = 38;
               break;
 
-            case 35:
-              _context.prev = 35;
+            case 34:
+              _context.prev = 34;
               _context.t1 = _context['catch'](3);
@@ -114,5 +114,5 @@ _didIteratorError = true;
 
-            case 39:
+            case 38:
+              _context.prev = 38;
               _context.prev = 39;
-              _context.prev = 40;
 
@@ -123,7 +123,7 @@ if (!_iteratorNormalCompletion && _iterator.return) {
 
-            case 42:
-              _context.prev = 42;
+            case 41:
+              _context.prev = 41;
 
               if (!_didIteratorError) {
-                _context.next = 45;
+                _context.next = 44;
                 break;
@@ -134,9 +134,9 @@ }
 
+            case 44:
+              return _context.finish(41);
+
             case 45:
-              return _context.finish(42);
+              return _context.finish(38);
 
             case 46:
-              return _context.finish(39);
-
-            case 47:
             case 'end':
@@ -146,3 +146,3 @@ return _context.stop();
         }
-      }, _callee, undefined, [[3, 35, 39, 47], [9, 26], [40,, 42, 46]]);
+      }, _callee, undefined, [[3, 34, 38, 46], [9, 25], [39,, 41, 45]]);
     }));
@@ -149,0 +149,0 @@

package.json

 {
   "name": "steveo",
-  "version": "1.0.27",
+  "version": "1.0.28",
   "description": "A Task Manager Library",
@@ -54,3 +54,3 @@ "main": "lib/index.js",
     "babel-register": "^6.24.0",
-    "chai": "^3.5.0",
+    "chai": "^4.0.0",
     "eslint": "^3.18.0",
@@ -61,8 +61,8 @@ "eslint-config-airbnb": "^15.0.1",
     "eslint-plugin-react": "^7.0.0",
-    "flow-bin": "^0.46.0",
+    "flow-bin": "^0.47.0",
     "flow-coverage-report": "^0.3.0",
     "mocha": "^3.2.0",
-    "nyc": "^10.1.2",
+    "nyc": "^11.0.0",
     "sinon": "^2.1.0"
   }
 }

No alert changes

Improved metrics

Total package byte prevSize

32500

increased by0.01%

No dependency changes