@temporalio/workflow - npm Package Compare versions

Comparing version 1.9.0-rc.0 to 1.9.0

lib/errors.js

@@ -17,6 +17,6 @@ "use strict";
 };
-WorkflowError = __decorate([
+exports.WorkflowError = WorkflowError;
+exports.WorkflowError = WorkflowError = __decorate([
     (0, type_helpers_1.SymbolBasedInstanceOfError)('WorkflowError')
 ], WorkflowError);
-exports.WorkflowError = WorkflowError;
 /**
@@ -27,6 +27,6 @@ * Thrown in workflow when it tries to do something that non-deterministic such as construct a WeakRef()
 };
-DeterminismViolationError = __decorate([
+exports.DeterminismViolationError = DeterminismViolationError;
+exports.DeterminismViolationError = DeterminismViolationError = __decorate([
     (0, type_helpers_1.SymbolBasedInstanceOfError)('DeterminismViolationError')
 ], DeterminismViolationError);
-exports.DeterminismViolationError = DeterminismViolationError;
 /**
@@ -41,6 +41,6 @@ * A class that acts as a marker for this special result type
 };
-LocalActivityDoBackoff = __decorate([
+exports.LocalActivityDoBackoff = LocalActivityDoBackoff;
+exports.LocalActivityDoBackoff = LocalActivityDoBackoff = __decorate([
     (0, type_helpers_1.SymbolBasedInstanceOfError)('LocalActivityDoBackoff')
 ], LocalActivityDoBackoff);
-exports.LocalActivityDoBackoff = LocalActivityDoBackoff;
 /**
@@ -47,0 +47,0 @@ * Returns whether provided `err` is caused by cancellation

lib/interfaces.d.ts

@@ -128,2 +128,9 @@ import type { RawSourceMap } from 'source-map';
     readonly cronScheduleToScheduleInterval?: number;
+    /**
+     * The Build ID of the worker which executed the current Workflow Task. May be undefined if the
+     * task was completed by a worker without a Build ID. If this worker is the one executing this
+     * task for the first time and has a Build ID set, then its ID will be used. This value may change
+     * over the lifetime of the workflow run, but is deterministic and safe to use for branching.
+     */
+    readonly currentBuildId?: string;
     readonly unsafe: UnsafeWorkflowInfo;
@@ -130,0 +137,0 @@ }

lib/interfaces.js

@@ -20,6 +20,6 @@ "use strict";
 };
-ContinueAsNew = __decorate([
+exports.ContinueAsNew = ContinueAsNew;
+exports.ContinueAsNew = ContinueAsNew = __decorate([
     (0, type_helpers_1.SymbolBasedInstanceOfError)('ContinueAsNew')
 ], ContinueAsNew);
-exports.ContinueAsNew = ContinueAsNew;
 /**
@@ -56,3 +56,3 @@ * Specifies:
     ChildWorkflowCancellationType[ChildWorkflowCancellationType["WAIT_CANCELLATION_REQUESTED"] = 3] = "WAIT_CANCELLATION_REQUESTED";
-})(ChildWorkflowCancellationType = exports.ChildWorkflowCancellationType || (exports.ChildWorkflowCancellationType = {}));
+})(ChildWorkflowCancellationType || (exports.ChildWorkflowCancellationType = ChildWorkflowCancellationType = {}));
 (0, type_helpers_1.checkExtends)();
@@ -85,5 +85,5 @@ (0, type_helpers_1.checkExtends)();
     ParentClosePolicy[ParentClosePolicy["PARENT_CLOSE_POLICY_REQUEST_CANCEL"] = 3] = "PARENT_CLOSE_POLICY_REQUEST_CANCEL";
-})(ParentClosePolicy = exports.ParentClosePolicy || (exports.ParentClosePolicy = {}));
+})(ParentClosePolicy || (exports.ParentClosePolicy = ParentClosePolicy = {}));
 (0, type_helpers_1.checkExtends)();
 (0, type_helpers_1.checkExtends)();
 //# sourceMappingURL=interfaces.js.map

lib/worker-interface.js

@@ -180,2 +180,3 @@ "use strict";
                 continueAsNewSuggested: activation.continueAsNewSuggested ?? false,
+                currentBuildId: activation.buildIdForCurrentTask ?? undefined,
                 unsafe: {
@@ -182,0 +183,0 @@ ...info.unsafe,

lib/workflow.js

@@ -283,3 +283,3 @@ "use strict";
                 workflowTaskTimeout: (0, time_1.msOptionalToTs)(options.workflowTaskTimeout),
-                namespace: activator.info.namespace,
+                namespace: activator.info.namespace, // Not configurable
                 headers,
@@ -286,0 +286,0 @@ cancellationType: options.cancellationType,

package.json

 {
   "name": "@temporalio/workflow",
-  "version": "1.9.0-rc.0",
+  "version": "1.9.0",
   "description": "Temporal.io SDK Workflow sub-package",
@@ -25,4 +25,4 @@ "keywords": [
   "dependencies": {
-    "@temporalio/common": "1.9.0-rc.0",
-    "@temporalio/proto": "1.9.0-rc.0"
+    "@temporalio/common": "1.9.0",
+    "@temporalio/proto": "1.9.0"
   },
@@ -39,3 +39,3 @@ "devDependencies": {
   ],
-  "gitHead": "ca3e508e62de02b2c9bb40d0d889003cebba282d"
+  "gitHead": "5096976287616207edcd3e4281a2a5e1f7393e33"
 }

src/interfaces.ts

@@ -165,2 +165,10 @@ import type { RawSourceMap } from 'source-map';
 
+  /**
+   * The Build ID of the worker which executed the current Workflow Task. May be undefined if the
+   * task was completed by a worker without a Build ID. If this worker is the one executing this
+   * task for the first time and has a Build ID set, then its ID will be used. This value may change
+   * over the lifetime of the workflow run, but is deterministic and safe to use for branching.
+   */
+  readonly currentBuildId?: string;
+
   readonly unsafe: UnsafeWorkflowInfo;
@@ -442,10 +450,10 @@ }
   Args extends any[],
-  T extends UpdateDefinition<Ret, Args> | SignalDefinition<Args> | QueryDefinition<Ret, Args>
+  T extends UpdateDefinition<Ret, Args> | SignalDefinition<Args> | QueryDefinition<Ret, Args>,
 > = T extends UpdateDefinition<infer R, infer A>
   ? (...args: A) => R | Promise<R>
   : T extends SignalDefinition<infer A>
-  ? (...args: A) => void | Promise<void>
-  : T extends QueryDefinition<infer R, infer A>
-  ? (...args: A) => R
-  : never;
+    ? (...args: A) => void | Promise<void>
+    : T extends QueryDefinition<infer R, infer A>
+      ? (...args: A) => R
+      : never;
 
@@ -452,0 +460,0 @@ /**

src/worker-interface.ts

@@ -202,2 +202,3 @@ /**
         continueAsNewSuggested: activation.continueAsNewSuggested ?? false,
+        currentBuildId: activation.buildIdForCurrentTask ?? undefined,
         unsafe: {
@@ -204,0 +205,0 @@ ...info.unsafe,

src/workflow.ts

@@ -1242,3 +1242,3 @@ import {
   Args extends any[],
-  T extends UpdateDefinition<Ret, Args> | SignalDefinition<Args> | QueryDefinition<Ret, Args>
+  T extends UpdateDefinition<Ret, Args> | SignalDefinition<Args> | QueryDefinition<Ret, Args>,
 >(def: T, handler: Handler<Ret, Args, T> | undefined, options?: { validator: UpdateValidator<Args> }): void {
@@ -1245,0 +1245,0 @@ const activator = assertInWorkflowContext('Workflow.setHandler(...) may only be used from a Workflow Execution.');

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

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

395397

increased by0.73%

Lines of code

8152

increased by0.2%

Number of low quality alerts

0

decreased by-100%

Dependency changes

• + Added@temporalio/common@1.9.0(transitive)

• + Added@temporalio/proto@1.9.0(transitive)

• + Addedproto3-json-serializer@2.0.2(transitive)

• - Removed@temporalio/common@1.9.0-rc.0(transitive)

• - Removed@temporalio/proto@1.9.0-rc.0(transitive)

• - Removedproto3-json-serializer@1.1.1(transitive)

• Updated@temporalio/common@1.9.0

• Updated@temporalio/proto@1.9.0