@travetto/worker - npm Package Compare versions

Comparing version 1.0.1 to 1.0.2

package.json

@@ -12,3 +12,3 @@ {
   "dependencies": {
-    "@travetto/base": "^1.0.1",
+    "@travetto/base": "^1.0.2",
     "@types/generic-pool": "^3.1.9",
@@ -35,4 +35,4 @@ "generic-pool": "^3.7.1"
   },
-  "version": "1.0.1",
-  "gitHead": "8f3d485c2997143df05241d7d12a24dd46525071"
+  "version": "1.0.2",
+  "gitHead": "9ca7c2f3ea75622df49ef9773aa9dd7340aa580f"
 }

README.md

@@ -103,3 +103,5 @@ <!-- This file was generated by the framweork and should not be modified directly -->
     const channel = new ParentCommChannel(
-      ExecUtil.fork(command, args, opts)
+      ExecUtil.fork(command, args, {
+        ...(opts ?? {})
+      })
     );
@@ -106,0 +108,0 @@ return {

src/comm/channel.ts

@@ -8,3 +8,3 @@ import { ChildProcess } from 'child_process';
 
-  public proc: T;
+  proc: T;
 
@@ -11,0 +11,0 @@ constructor(proc: T) {

src/pool.ts

@@ -130,2 +130,3 @@ import * as os from 'os';
       const worker = (await this.pool.acquire())!;
+      console.debug(`[${process.pid}] Acquired ${worker.id}`);
       const nextInput = await src.next();
@@ -132,0 +133,0 @@

src/util.ts

@@ -25,3 +25,5 @@ import { ExecUtil, ExecutionOptions, } from '@travetto/boot';
     const channel = new ParentCommChannel(
-      ExecUtil.fork(command, args, opts)
+      ExecUtil.fork(command, args, {
+        ...(opts ?? {})
+      })
     );
@@ -28,0 +30,0 @@ return {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

27063

increased by0.42%

Lines of code

578

increased by0.52%

Dependency changes

• Updated@travetto/base@^1.0.2