@temporalio/client - npm Package Compare versions

Comparing version 1.9.0-rc.0 to 1.9.0

lib/async-completion-client.js

@@ -23,6 +23,6 @@ "use strict";
 };
-ActivityNotFoundError = __decorate([
+exports.ActivityNotFoundError = ActivityNotFoundError;
+exports.ActivityNotFoundError = ActivityNotFoundError = __decorate([
     (0, type_helpers_1.SymbolBasedInstanceOfError)('ActivityNotFoundError')
 ], ActivityNotFoundError);
-exports.ActivityNotFoundError = ActivityNotFoundError;
 /**
@@ -34,6 +34,6 @@ * Thrown by {@link AsyncCompletionClient} when trying to complete or heartbeat
 };
-ActivityCompletionError = __decorate([
+exports.ActivityCompletionError = ActivityCompletionError;
+exports.ActivityCompletionError = ActivityCompletionError = __decorate([
     (0, type_helpers_1.SymbolBasedInstanceOfError)('ActivityCompletionError')
 ], ActivityCompletionError);
-exports.ActivityCompletionError = ActivityCompletionError;
 /**
@@ -45,6 +45,6 @@ * Thrown by {@link AsyncCompletionClient.heartbeat} when the Workflow has
 };
-ActivityCancelledError = __decorate([
+exports.ActivityCancelledError = ActivityCancelledError;
+exports.ActivityCancelledError = ActivityCancelledError = __decorate([
     (0, type_helpers_1.SymbolBasedInstanceOfError)('ActivityCancelledError')
 ], ActivityCancelledError);
-exports.ActivityCancelledError = ActivityCancelledError;
 function defaultAsyncCompletionClientOptions() {
@@ -51,0 +51,0 @@ return (0, base_client_1.defaultBaseClientOptions)();

lib/errors.js

@@ -20,6 +20,6 @@ "use strict";
 };
-ServiceError = __decorate([
+exports.ServiceError = ServiceError;
+exports.ServiceError = ServiceError = __decorate([
     (0, type_helpers_1.SymbolBasedInstanceOfError)('ServiceError')
 ], ServiceError);
-exports.ServiceError = ServiceError;
 /**
@@ -41,6 +41,6 @@ * Thrown by the client while waiting on Workflow execution result if execution
 };
-WorkflowFailedError = __decorate([
+exports.WorkflowFailedError = WorkflowFailedError;
+exports.WorkflowFailedError = WorkflowFailedError = __decorate([
     (0, type_helpers_1.SymbolBasedInstanceOfError)('WorkflowFailedError')
 ], WorkflowFailedError);
-exports.WorkflowFailedError = WorkflowFailedError;
 /**
@@ -56,6 +56,6 @@ * Thrown by the client while waiting on Workflow Update result if Update
 };
-WorkflowUpdateFailedError = __decorate([
+exports.WorkflowUpdateFailedError = WorkflowUpdateFailedError;
+exports.WorkflowUpdateFailedError = WorkflowUpdateFailedError = __decorate([
     (0, type_helpers_1.SymbolBasedInstanceOfError)('WorkflowUpdateFailedError')
 ], WorkflowUpdateFailedError);
-exports.WorkflowUpdateFailedError = WorkflowUpdateFailedError;
 /**
@@ -73,6 +73,6 @@ * Thrown the by client while waiting on Workflow execution result if Workflow
 };
-WorkflowContinuedAsNewError = __decorate([
+exports.WorkflowContinuedAsNewError = WorkflowContinuedAsNewError;
+exports.WorkflowContinuedAsNewError = WorkflowContinuedAsNewError = __decorate([
     (0, type_helpers_1.SymbolBasedInstanceOfError)('WorkflowExecutionContinuedAsNewError')
 ], WorkflowContinuedAsNewError);
-exports.WorkflowContinuedAsNewError = WorkflowContinuedAsNewError;
 function isGrpcServiceError(err) {
@@ -79,0 +79,0 @@ return ((0, type_helpers_1.isError)(err) &&

lib/schedule-client.js

@@ -363,6 +363,6 @@ "use strict";
 };
-ScheduleAlreadyRunning = __decorate([
+exports.ScheduleAlreadyRunning = ScheduleAlreadyRunning;
+exports.ScheduleAlreadyRunning = ScheduleAlreadyRunning = __decorate([
     (0, type_helpers_1.SymbolBasedInstanceOfError)('ScheduleAlreadyRunning')
 ], ScheduleAlreadyRunning);
-exports.ScheduleAlreadyRunning = ScheduleAlreadyRunning;
 /**
@@ -380,6 +380,6 @@ * Thrown when a Schedule with the given Id is not known to Temporal Server.
 };
-ScheduleNotFoundError = __decorate([
+exports.ScheduleNotFoundError = ScheduleNotFoundError;
+exports.ScheduleNotFoundError = ScheduleNotFoundError = __decorate([
     (0, type_helpers_1.SymbolBasedInstanceOfError)('ScheduleNotFoundError')
 ], ScheduleNotFoundError);
-exports.ScheduleNotFoundError = ScheduleNotFoundError;
 //# sourceMappingURL=schedule-client.js.map

lib/schedule-types.js

@@ -69,5 +69,5 @@ "use strict";
     ScheduleOverlapPolicy[ScheduleOverlapPolicy["ALLOW_ALL"] = 6] = "ALLOW_ALL";
-})(ScheduleOverlapPolicy = exports.ScheduleOverlapPolicy || (exports.ScheduleOverlapPolicy = {}));
+})(ScheduleOverlapPolicy || (exports.ScheduleOverlapPolicy = ScheduleOverlapPolicy = {}));
 (0, type_helpers_1.checkExtends)();
 (0, type_helpers_1.checkExtends)();
 //# sourceMappingURL=schedule-types.js.map

lib/task-queue-client.js

@@ -230,6 +230,6 @@ "use strict";
 };
-BuildIdNotFoundError = __decorate([
+exports.BuildIdNotFoundError = BuildIdNotFoundError;
+exports.BuildIdNotFoundError = BuildIdNotFoundError = __decorate([
     (0, type_helpers_1.SymbolBasedInstanceOfError)('BuildIdNotFoundError')
 ], BuildIdNotFoundError);
-exports.BuildIdNotFoundError = BuildIdNotFoundError;
 //# sourceMappingURL=task-queue-client.js.map

lib/workflow-client.d.ts

@@ -85,5 +85,5 @@ import { status as grpcStatus } from '@grpc/grpc-js';
     /**
-     * Get a handle to an Update.
+     * Get a handle to an Update of this Workflow.
      */
-    getUpdateHandle<Ret>(updateId: string, workflowId: string, options?: GetWorkflowUpdateHandleOptions): WorkflowUpdateHandle<Ret>;
+    getUpdateHandle<Ret>(updateId: string): WorkflowUpdateHandle<Ret>;
     /**
@@ -315,3 +315,3 @@ * Query a running or completed Workflow.
      * Sends a signal to a running Workflow or starts a new one if not already running and immediately signals it.
-     * Useful when you're unsure of the Workflows' run state.
+     * Useful when you're unsure of the Workflow's run state.
      *
@@ -359,3 +359,3 @@ * @returns the runId of the Workflow
     protected _startUpdateHandler(waitForStage: temporal.api.enums.v1.UpdateWorkflowExecutionLifecycleStage, input: WorkflowStartUpdateInput): Promise<WorkflowStartUpdateOutput>;
-    protected createWorkflowUpdateHandle<Ret>(updateId: string, workflowId: string, options?: GetWorkflowUpdateHandleOptions, outcome?: temporal.api.update.v1.IOutcome): WorkflowUpdateHandle<Ret>;
+    protected createWorkflowUpdateHandle<Ret>(updateId: string, workflowId: string, workflowRunId?: string, outcome?: temporal.api.update.v1.IOutcome): WorkflowUpdateHandle<Ret>;
     /**
@@ -362,0 +362,0 @@ * Poll Update until a response with an outcome is received; return that outcome.

lib/workflow-client.js

@@ -83,3 +83,3 @@ "use strict";
      * Sends a signal to a running Workflow or starts a new one if not already running and immediately signals it.
-     * Useful when you're unsure of the Workflows' run state.
+     * Useful when you're unsure of the Workflow's run state.
      *
@@ -139,3 +139,3 @@ * @returns the runId of the Workflow
             runId: undefined,
-            firstExecutionRunId: undefined,
+            firstExecutionRunId: undefined, // We don't know if this runId is first in the chain or not
             runIdForResult: runId,
@@ -338,4 +338,3 @@ interceptors,
     }
-    createWorkflowUpdateHandle(updateId, workflowId, options, outcome) {
-        const workflowRunId = options?.workflowRunId;
+    createWorkflowUpdateHandle(updateId, workflowId, workflowRunId, outcome) {
         return {
@@ -581,3 +580,3 @@ updateId,
             const output = await fn(input);
-            return this.createWorkflowUpdateHandle(output.updateId, input.workflowExecution.workflowId, { workflowRunId: output.workflowRunId }, output.outcome);
+            return this.createWorkflowUpdateHandle(output.updateId, input.workflowExecution.workflowId, output.workflowRunId, output.outcome);
         };
@@ -644,4 +643,4 @@ return {
             },
-            getUpdateHandle(updateId, workflowId, options) {
-                return this.client.createWorkflowUpdateHandle(updateId, workflowId, options);
+            getUpdateHandle(updateId) {
+                return this.client.createWorkflowUpdateHandle(updateId, workflowId, runId);
             },
@@ -763,6 +762,6 @@ async signal(def, ...args) {
 };
-QueryRejectedError = __decorate([
+exports.QueryRejectedError = QueryRejectedError;
+exports.QueryRejectedError = QueryRejectedError = __decorate([
     (0, type_helpers_1.SymbolBasedInstanceOfError)('QueryRejectedError')
 ], QueryRejectedError);
-exports.QueryRejectedError = QueryRejectedError;
 let QueryNotRegisteredError = class QueryNotRegisteredError extends Error {
@@ -774,6 +773,6 @@ constructor(message, code) {
 };
-QueryNotRegisteredError = __decorate([
+exports.QueryNotRegisteredError = QueryNotRegisteredError;
+exports.QueryNotRegisteredError = QueryNotRegisteredError = __decorate([
     (0, type_helpers_1.SymbolBasedInstanceOfError)('QueryNotRegisteredError')
 ], QueryNotRegisteredError);
-exports.QueryNotRegisteredError = QueryNotRegisteredError;
 //# sourceMappingURL=workflow-client.js.map

package.json

 {
   "name": "@temporalio/client",
-  "version": "1.9.0-rc.0",
+  "version": "1.9.0",
   "description": "Temporal.io SDK Client sub-package",
@@ -17,7 +17,7 @@ "main": "lib/index.js",
     "@grpc/grpc-js": "~1.7.3",
-    "@temporalio/common": "1.9.0-rc.0",
-    "@temporalio/proto": "1.9.0-rc.0",
+    "@temporalio/common": "1.9.0",
+    "@temporalio/proto": "1.9.0",
     "abort-controller": "^3.0.0",
-    "long": "^5.2.0",
-    "uuid": "^8.3.2"
+    "long": "^5.2.3",
+    "uuid": "^9.0.1"
   },
@@ -43,3 +43,3 @@ "devDependencies": {
   ],
-  "gitHead": "ca3e508e62de02b2c9bb40d0d889003cebba282d"
+  "gitHead": "5096976287616207edcd3e4281a2a5e1f7393e33"
 }

src/errors.ts

@@ -44,3 +44,6 @@ import { ServiceError as GrpcServiceError } from '@grpc/grpc-js';
 export class WorkflowUpdateFailedError extends Error {
-  public constructor(message: string, public readonly cause: TemporalFailure | undefined) {
+  public constructor(
+    message: string,
+    public readonly cause: TemporalFailure | undefined
+  ) {
     super(message);
@@ -58,3 +61,6 @@ }
 export class WorkflowContinuedAsNewError extends Error {
-  public constructor(message: string, public readonly newExecutionRunId: string) {
+  public constructor(
+    message: string,
+    public readonly newExecutionRunId: string
+  ) {
     super(message);
@@ -61,0 +67,0 @@ }

src/schedule-client.ts

@@ -522,3 +522,6 @@ import { status as grpcStatus } from '@grpc/grpc-js';
 export class ScheduleAlreadyRunning extends Error {
-  constructor(message: string, public readonly scheduleId: string) {
+  constructor(
+    message: string,
+    public readonly scheduleId: string
+  ) {
     super(message);
@@ -536,5 +539,8 @@ }
 export class ScheduleNotFoundError extends Error {
-  constructor(message: string, public readonly scheduleId: string) {
+  constructor(
+    message: string,
+    public readonly scheduleId: string
+  ) {
     super(message);
   }
 }

src/workflow-client.ts

@@ -168,9 +168,5 @@ import { status as grpcStatus } from '@grpc/grpc-js';
   /**
-   * Get a handle to an Update.
+   * Get a handle to an Update of this Workflow.
    */
-  getUpdateHandle<Ret>(
-    updateId: string,
-    workflowId: string,
-    options?: GetWorkflowUpdateHandleOptions
-  ): WorkflowUpdateHandle<Ret>;
+  getUpdateHandle<Ret>(updateId: string): WorkflowUpdateHandle<Ret>;
 
@@ -480,3 +476,3 @@ /**
    * Sends a signal to a running Workflow or starts a new one if not already running and immediately signals it.
-   * Useful when you're unsure of the Workflows' run state.
+   * Useful when you're unsure of the Workflow's run state.
    *
@@ -804,6 +800,5 @@ * @returns the runId of the Workflow
     workflowId: string,
-    options?: GetWorkflowUpdateHandleOptions,
+    workflowRunId?: string,
     outcome?: temporal.api.update.v1.IOutcome
   ): WorkflowUpdateHandle<Ret> {
-    const workflowRunId = options?.workflowRunId;
     return {
@@ -1083,3 +1078,3 @@ updateId,
         input.workflowExecution.workflowId,
-        { workflowRunId: output.workflowRunId },
+        output.workflowRunId,
         output.outcome
@@ -1163,8 +1158,4 @@ );
       },
-      getUpdateHandle<Ret>(
-        updateId: string,
-        workflowId: string,
-        options?: GetWorkflowUpdateHandleOptions
-      ): WorkflowUpdateHandle<Ret> {
-        return this.client.createWorkflowUpdateHandle(updateId, workflowId, options);
+      getUpdateHandle<Ret>(updateId: string): WorkflowUpdateHandle<Ret> {
+        return this.client.createWorkflowUpdateHandle(updateId, workflowId, runId);
       },
@@ -1300,5 +1291,8 @@ async signal<Args extends any[]>(def: SignalDefinition<Args> | string, ...args: Args): Promise<void> {
 export class QueryNotRegisteredError extends Error {
-  constructor(message: string, public readonly code: grpcStatus) {
+  constructor(
+    message: string,
+    public readonly code: grpcStatus
+  ) {
     super(message);
   }
 }

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

503146

increased by0.31%

Lines of code

10454

increased by0.05%

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)

• + Addeduuid@9.0.1(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)

• - Removeduuid@8.3.2(transitive)

• Updated@temporalio/common@1.9.0

• Updated@temporalio/proto@1.9.0

• Updatedlong@^5.2.3

• Updateduuid@^9.0.1