@temporalio/worker - npm Package Compare versions

Comparing version 1.1.0 to 1.2.0

lib/index.d.ts

@@ -23,1 +23,2 @@ /**
 export { BundleOptions, bundleWorkflowCode, WorkflowBundleWithSourceMap } from './workflow/bundler';
+export { startDebugReplayer } from './debug-replayer';

lib/index.js

@@ -26,3 +26,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.bundleWorkflowCode = exports.workflowLogAttributes = exports.WorkflowInboundLogInterceptor = exports.defaultSinks = exports.appendDefaultInterceptors = exports.Worker = exports.errors = exports.defaultPayloadConverter = exports.Runtime = exports.NativeConnection = exports.activityLogAttributes = exports.ActivityInboundLogInterceptor = void 0;
+exports.startDebugReplayer = exports.bundleWorkflowCode = exports.workflowLogAttributes = exports.WorkflowInboundLogInterceptor = exports.defaultSinks = exports.appendDefaultInterceptors = exports.Worker = exports.errors = exports.defaultPayloadConverter = exports.Runtime = exports.NativeConnection = exports.activityLogAttributes = exports.ActivityInboundLogInterceptor = void 0;
 var activity_log_interceptor_1 = require("./activity-log-interceptor");
@@ -51,2 +51,4 @@ Object.defineProperty(exports, "ActivityInboundLogInterceptor", { enumerable: true, get: function () { return activity_log_interceptor_1.ActivityInboundLogInterceptor; } });
 Object.defineProperty(exports, "bundleWorkflowCode", { enumerable: true, get: function () { return bundler_1.bundleWorkflowCode; } });
+var debug_replayer_1 = require("./debug-replayer");
+Object.defineProperty(exports, "startDebugReplayer", { enumerable: true, get: function () { return debug_replayer_1.startDebugReplayer; } });
 //# sourceMappingURL=index.js.map

lib/workflow/bundler.js

@@ -30,3 +30,2 @@ "use strict";
 exports.bundleWorkflowCode = exports.WorkflowCodeBundler = exports.moduleMatches = exports.disallowedModules = exports.disallowedBuiltinModules = exports.allowedBuiltinModules = void 0;
-const crypto_1 = __importDefault(require("crypto"));
 const realFS = __importStar(require("fs"));
@@ -118,3 +117,3 @@ const memfs = __importStar(require("memfs"));
             const { root, dir, name } = path_1.default.parse(workflowsPath);
-            return path_1.default.format({ root, dir, base: `${name}-entrypoint-${crypto_1.default.randomBytes(8).toString('hex')}.js` });
+            return path_1.default.format({ root, dir, base: `${name}-autogenerated-entrypoint.js` });
         }
@@ -124,3 +123,3 @@ else {
             const { root, dir, base } = path_1.default.parse(workflowsPath);
-            return path_1.default.format({ root, dir, base: `${base}-entrypoint-${crypto_1.default.randomBytes(8).toString('hex')}.js` });
+            return path_1.default.format({ root, dir, base: `${base}-autogenerated-entrypoint.js` });
         }
@@ -220,3 +219,3 @@ }
                 path: distDir,
-                filename: 'workflow-isolate-[fullhash].js',
+                filename: 'workflow-bundle-[fullhash].js',
                 devtoolModuleFilenameTemplate: '[absolute-resource-path]',
@@ -223,0 +222,0 @@ library: '__TEMPORAL__',

lib/workflow/vm.d.ts

@@ -5,3 +5,3 @@ /// <reference types="node" />
 import { SinkCall } from '@temporalio/workflow/lib/sinks';
-import type * as internals from '@temporalio/workflow/lib/worker-interface';
+import * as internals from '@temporalio/workflow/lib/worker-interface';
 import { RawSourceMap } from 'source-map';
@@ -8,0 +8,0 @@ import vm from 'vm';

lib/workflow/vm.js

 "use strict";
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    var desc = Object.getOwnPropertyDescriptor(m, k);
+    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+      desc = { enumerable: true, get: function() { return m[k]; } };
+    }
+    Object.defineProperty(o, k2, desc);
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
+    Object.defineProperty(o, "default", { enumerable: true, value: v });
+}) : function(o, v) {
+    o["default"] = v;
+});
+var __importStar = (this && this.__importStar) || function (mod) {
+    if (mod && mod.__esModule) return mod;
+    var result = {};
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    __setModuleDefault(result, mod);
+    return result;
+};
 var __importDefault = (this && this.__importDefault) || function (mod) {
@@ -9,2 +32,3 @@ return (mod && mod.__esModule) ? mod : { "default": mod };
 const proto_1 = require("@temporalio/proto");
+const internals = __importStar(require("@temporalio/workflow/lib/worker-interface"));
 const assert_1 = __importDefault(require("assert"));
@@ -340,3 +364,5 @@ const async_hooks_1 = require("async_hooks");
             this.workflowModule.activate(proto_1.coresdk.workflow_activation.WorkflowActivation.fromObject({ ...activation, jobs }), batchIndex++);
-            await this.tryUnblockConditions();
+            if (internals.showUnblockConditions(jobs[0])) {
+                await this.tryUnblockConditions();
+            }
         }
@@ -343,0 +369,0 @@ const completion = this.workflowModule.concludeActivation();

package.json

 {
   "name": "@temporalio/worker",
-  "version": "1.1.0",
+  "version": "1.2.0",
   "description": "Temporal.io SDK Worker sub-package",
@@ -24,3 +24,3 @@ "main": "lib/index.js",
     "@temporalio/proto": "^1.1.0",
-    "@temporalio/workflow": "^1.1.0",
+    "@temporalio/workflow": "^1.2.0",
     "abort-controller": "^3.0.0",
@@ -54,3 +54,3 @@ "cargo-cp-artifact": "^0.1.6",
   ],
-  "gitHead": "132f23a47a93fecf3f39836b31f08ea837b30320"
+  "gitHead": "9790992f0a7da1638cd3db99518e414107651630"
 }

src/index.ts

@@ -43,1 +43,2 @@ /**
 export { BundleOptions, bundleWorkflowCode, WorkflowBundleWithSourceMap } from './workflow/bundler';
+export { startDebugReplayer } from './debug-replayer';

src/workflow/bundler.ts

@@ -1,2 +0,1 @@
-import crypto from 'crypto';
 import * as realFS from 'fs';
@@ -124,7 +123,7 @@ import * as memfs from 'memfs';
       const { root, dir, name } = path.parse(workflowsPath);
-      return path.format({ root, dir, base: `${name}-entrypoint-${crypto.randomBytes(8).toString('hex')}.js` });
+      return path.format({ root, dir, base: `${name}-autogenerated-entrypoint.js` });
     } else {
       // workflowsPath is a directory; make the entrypoint a sibling of that directory
       const { root, dir, base } = path.parse(workflowsPath);
-      return path.format({ root, dir, base: `${base}-entrypoint-${crypto.randomBytes(8).toString('hex')}.js` });
+      return path.format({ root, dir, base: `${base}-autogenerated-entrypoint.js` });
     }
@@ -236,3 +235,3 @@ }
         path: distDir,
-        filename: 'workflow-isolate-[fullhash].js',
+        filename: 'workflow-bundle-[fullhash].js',
         devtoolModuleFilenameTemplate: '[absolute-resource-path]',
@@ -239,0 +238,0 @@ library: '__TEMPORAL__',

src/workflow/vm.ts

@@ -5,3 +5,3 @@ import { cutoffStackTrace, IllegalStateError } from '@temporalio/common';
 import { SinkCall } from '@temporalio/workflow/lib/sinks';
-import type * as internals from '@temporalio/workflow/lib/worker-interface';
+import * as internals from '@temporalio/workflow/lib/worker-interface';
 import assert from 'assert';
@@ -401,3 +401,5 @@ import { AsyncLocalStorage } from 'async_hooks';
       );
-      await this.tryUnblockConditions();
+      if (internals.showUnblockConditions(jobs[0])) {
+        await this.tryUnblockConditions();
+      }
     }
@@ -404,0 +406,0 @@ const completion = this.workflowModule.concludeActivation();

New alerts

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

576648

6.24%

Number of package files

131

22.43%

Lines of code

10682

7.13%

Worsened metrics

Number of low supply chain risk alerts

12

20%

Dependency changes

• Updated

  @temporalio/workflow@^1.2.0