@temporalio/common
Advanced tools
Comparing version 1.9.0-rc.0 to 1.9.0
@@ -12,5 +12,5 @@ "use strict"; | ||
ActivityCancellationType[ActivityCancellationType["ABANDON"] = 2] = "ABANDON"; | ||
})(ActivityCancellationType = exports.ActivityCancellationType || (exports.ActivityCancellationType = {})); | ||
})(ActivityCancellationType || (exports.ActivityCancellationType = ActivityCancellationType = {})); | ||
(0, type_helpers_1.checkExtends)(); | ||
(0, type_helpers_1.checkExtends)(); | ||
//# sourceMappingURL=activity-options.js.map |
@@ -21,6 +21,6 @@ "use strict"; | ||
}; | ||
ValueError = __decorate([ | ||
exports.ValueError = ValueError; | ||
exports.ValueError = ValueError = __decorate([ | ||
(0, type_helpers_1.SymbolBasedInstanceOfError)('ValueError') | ||
], ValueError); | ||
exports.ValueError = ValueError; | ||
/** | ||
@@ -31,6 +31,6 @@ * Thrown when a Payload Converter is misconfigured. | ||
}; | ||
PayloadConverterError = __decorate([ | ||
exports.PayloadConverterError = PayloadConverterError; | ||
exports.PayloadConverterError = PayloadConverterError = __decorate([ | ||
(0, type_helpers_1.SymbolBasedInstanceOfError)('PayloadConverterError') | ||
], PayloadConverterError); | ||
exports.PayloadConverterError = PayloadConverterError; | ||
/** | ||
@@ -41,6 +41,6 @@ * Used in different parts of the SDK to note that something unexpected has happened. | ||
}; | ||
IllegalStateError = __decorate([ | ||
exports.IllegalStateError = IllegalStateError; | ||
exports.IllegalStateError = IllegalStateError = __decorate([ | ||
(0, type_helpers_1.SymbolBasedInstanceOfError)('IllegalStateError') | ||
], IllegalStateError); | ||
exports.IllegalStateError = IllegalStateError; | ||
/** | ||
@@ -61,6 +61,6 @@ * This exception is thrown in the following cases: | ||
}; | ||
WorkflowExecutionAlreadyStartedError = __decorate([ | ||
exports.WorkflowExecutionAlreadyStartedError = WorkflowExecutionAlreadyStartedError; | ||
exports.WorkflowExecutionAlreadyStartedError = WorkflowExecutionAlreadyStartedError = __decorate([ | ||
(0, type_helpers_1.SymbolBasedInstanceOfError)('WorkflowExecutionAlreadyStartedError') | ||
], WorkflowExecutionAlreadyStartedError); | ||
exports.WorkflowExecutionAlreadyStartedError = WorkflowExecutionAlreadyStartedError; | ||
/** | ||
@@ -80,6 +80,6 @@ * Thrown when a Workflow with the given Id is not known to Temporal Server. | ||
}; | ||
WorkflowNotFoundError = __decorate([ | ||
exports.WorkflowNotFoundError = WorkflowNotFoundError; | ||
exports.WorkflowNotFoundError = WorkflowNotFoundError = __decorate([ | ||
(0, type_helpers_1.SymbolBasedInstanceOfError)('WorkflowNotFoundError') | ||
], WorkflowNotFoundError); | ||
exports.WorkflowNotFoundError = WorkflowNotFoundError; | ||
/** | ||
@@ -94,6 +94,6 @@ * Thrown when the specified namespace is not known to Temporal Server. | ||
}; | ||
NamespaceNotFoundError = __decorate([ | ||
exports.NamespaceNotFoundError = NamespaceNotFoundError; | ||
exports.NamespaceNotFoundError = NamespaceNotFoundError = __decorate([ | ||
(0, type_helpers_1.SymbolBasedInstanceOfError)('NamespaceNotFoundError') | ||
], NamespaceNotFoundError); | ||
exports.NamespaceNotFoundError = NamespaceNotFoundError; | ||
//# sourceMappingURL=errors.js.map |
@@ -21,3 +21,3 @@ "use strict"; | ||
TimeoutType[TimeoutType["TIMEOUT_TYPE_HEARTBEAT"] = 4] = "TIMEOUT_TYPE_HEARTBEAT"; | ||
})(TimeoutType = exports.TimeoutType || (exports.TimeoutType = {})); | ||
})(TimeoutType || (exports.TimeoutType = TimeoutType = {})); | ||
(0, type_helpers_1.checkExtends)(); | ||
@@ -37,3 +37,3 @@ (0, type_helpers_1.checkExtends)(); | ||
RetryState[RetryState["RETRY_STATE_CANCEL_REQUESTED"] = 7] = "RETRY_STATE_CANCEL_REQUESTED"; | ||
})(RetryState = exports.RetryState || (exports.RetryState = {})); | ||
})(RetryState || (exports.RetryState = RetryState = {})); | ||
(0, type_helpers_1.checkExtends)(); | ||
@@ -54,6 +54,6 @@ (0, type_helpers_1.checkExtends)(); | ||
}; | ||
TemporalFailure = __decorate([ | ||
exports.TemporalFailure = TemporalFailure; | ||
exports.TemporalFailure = TemporalFailure = __decorate([ | ||
(0, type_helpers_1.SymbolBasedInstanceOfError)('TemporalFailure') | ||
], TemporalFailure); | ||
exports.TemporalFailure = TemporalFailure; | ||
/** Exceptions originated at the Temporal service. */ | ||
@@ -66,6 +66,6 @@ let ServerFailure = class ServerFailure extends TemporalFailure { | ||
}; | ||
ServerFailure = __decorate([ | ||
exports.ServerFailure = ServerFailure; | ||
exports.ServerFailure = ServerFailure = __decorate([ | ||
(0, type_helpers_1.SymbolBasedInstanceOfError)('ServerFailure') | ||
], ServerFailure); | ||
exports.ServerFailure = ServerFailure; | ||
/** | ||
@@ -148,6 +148,6 @@ * `ApplicationFailure`s are used to communicate application-specific failures in Workflows and Activities. | ||
}; | ||
ApplicationFailure = __decorate([ | ||
exports.ApplicationFailure = ApplicationFailure; | ||
exports.ApplicationFailure = ApplicationFailure = __decorate([ | ||
(0, type_helpers_1.SymbolBasedInstanceOfError)('ApplicationFailure') | ||
], ApplicationFailure); | ||
exports.ApplicationFailure = ApplicationFailure; | ||
/** | ||
@@ -166,6 +166,6 @@ * This error is thrown when Cancellation has been requested. To allow Cancellation to happen, let it propagate. To | ||
}; | ||
CancelledFailure = __decorate([ | ||
exports.CancelledFailure = CancelledFailure; | ||
exports.CancelledFailure = CancelledFailure = __decorate([ | ||
(0, type_helpers_1.SymbolBasedInstanceOfError)('CancelledFailure') | ||
], CancelledFailure); | ||
exports.CancelledFailure = CancelledFailure; | ||
/** | ||
@@ -179,6 +179,6 @@ * Used as the `cause` when a Workflow has been terminated | ||
}; | ||
TerminatedFailure = __decorate([ | ||
exports.TerminatedFailure = TerminatedFailure; | ||
exports.TerminatedFailure = TerminatedFailure = __decorate([ | ||
(0, type_helpers_1.SymbolBasedInstanceOfError)('TerminatedFailure') | ||
], TerminatedFailure); | ||
exports.TerminatedFailure = TerminatedFailure; | ||
/** | ||
@@ -194,6 +194,6 @@ * Used to represent timeouts of Activities and Workflows | ||
}; | ||
TimeoutFailure = __decorate([ | ||
exports.TimeoutFailure = TimeoutFailure; | ||
exports.TimeoutFailure = TimeoutFailure = __decorate([ | ||
(0, type_helpers_1.SymbolBasedInstanceOfError)('TimeoutFailure') | ||
], TimeoutFailure); | ||
exports.TimeoutFailure = TimeoutFailure; | ||
/** | ||
@@ -214,6 +214,6 @@ * Contains information about an Activity failure. Always contains the original reason for the failure as its `cause`. | ||
}; | ||
ActivityFailure = __decorate([ | ||
exports.ActivityFailure = ActivityFailure; | ||
exports.ActivityFailure = ActivityFailure = __decorate([ | ||
(0, type_helpers_1.SymbolBasedInstanceOfError)('ActivityFailure') | ||
], ActivityFailure); | ||
exports.ActivityFailure = ActivityFailure; | ||
/** | ||
@@ -234,6 +234,6 @@ * Contains information about a Child Workflow failure. Always contains the reason for the failure as its {@link cause}. | ||
}; | ||
ChildWorkflowFailure = __decorate([ | ||
exports.ChildWorkflowFailure = ChildWorkflowFailure; | ||
exports.ChildWorkflowFailure = ChildWorkflowFailure = __decorate([ | ||
(0, type_helpers_1.SymbolBasedInstanceOfError)('ChildWorkflowFailure') | ||
], ChildWorkflowFailure); | ||
exports.ChildWorkflowFailure = ChildWorkflowFailure; | ||
/** | ||
@@ -240,0 +240,0 @@ * If `error` is already an `ApplicationFailure`, returns `error`. |
@@ -17,3 +17,3 @@ "use strict"; | ||
VersioningIntent[VersioningIntent["DEFAULT"] = 2] = "DEFAULT"; | ||
})(VersioningIntent = exports.VersioningIntent || (exports.VersioningIntent = {})); | ||
})(VersioningIntent || (exports.VersioningIntent = VersioningIntent = {})); | ||
(0, type_helpers_1.checkExtends)(); | ||
@@ -20,0 +20,0 @@ (0, type_helpers_1.checkExtends)(); |
@@ -39,3 +39,3 @@ "use strict"; | ||
WorkflowIdReusePolicy[WorkflowIdReusePolicy["WORKFLOW_ID_REUSE_POLICY_TERMINATE_IF_RUNNING"] = 4] = "WORKFLOW_ID_REUSE_POLICY_TERMINATE_IF_RUNNING"; | ||
})(WorkflowIdReusePolicy = exports.WorkflowIdReusePolicy || (exports.WorkflowIdReusePolicy = {})); | ||
})(WorkflowIdReusePolicy || (exports.WorkflowIdReusePolicy = WorkflowIdReusePolicy = {})); | ||
(0, type_helpers_1.checkExtends)(); | ||
@@ -42,0 +42,0 @@ (0, type_helpers_1.checkExtends)(); |
{ | ||
"name": "@temporalio/common", | ||
"version": "1.9.0-rc.0", | ||
"version": "1.9.0", | ||
"description": "Common library for code that's used across the Client, Worker, and/or Workflow", | ||
@@ -15,6 +15,8 @@ "main": "lib/index.js", | ||
"dependencies": { | ||
"@temporalio/proto": "1.9.0-rc.0", | ||
"long": "^5.2.0", | ||
"@temporalio/proto": "1.9.0", | ||
"long": "^5.2.3", | ||
"ms": "^3.0.0-canary.1", | ||
"proto3-json-serializer": "^1.0.3", | ||
"proto3-json-serializer": "^2.0.0" | ||
}, | ||
"devDependencies": { | ||
"protobufjs": "^7.2.5" | ||
@@ -38,3 +40,3 @@ }, | ||
], | ||
"gitHead": "ca3e508e62de02b2c9bb40d0d889003cebba282d" | ||
"gitHead": "5096976287616207edcd3e4281a2a5e1f7393e33" | ||
} |
@@ -9,3 +9,6 @@ import { TemporalFailure } from './failure'; | ||
export class ValueError extends Error { | ||
constructor(message: string | undefined, public readonly cause?: unknown) { | ||
constructor( | ||
message: string | undefined, | ||
public readonly cause?: unknown | ||
) { | ||
super(message ?? undefined); | ||
@@ -37,3 +40,7 @@ } | ||
export class WorkflowExecutionAlreadyStartedError extends TemporalFailure { | ||
constructor(message: string, public readonly workflowId: string, public readonly workflowType: string) { | ||
constructor( | ||
message: string, | ||
public readonly workflowId: string, | ||
public readonly workflowType: string | ||
) { | ||
super(message); | ||
@@ -52,3 +59,7 @@ } | ||
export class WorkflowNotFoundError extends Error { | ||
constructor(message: string, public readonly workflowId: string, public readonly runId: string | undefined) { | ||
constructor( | ||
message: string, | ||
public readonly workflowId: string, | ||
public readonly runId: string | undefined | ||
) { | ||
super(message); | ||
@@ -55,0 +66,0 @@ } |
@@ -54,3 +54,6 @@ import type { temporal } from '@temporalio/proto'; | ||
constructor(message?: string | undefined | null, public readonly cause?: Error) { | ||
constructor( | ||
message?: string | undefined | null, | ||
public readonly cause?: Error | ||
) { | ||
super(message ?? undefined); | ||
@@ -63,3 +66,7 @@ } | ||
export class ServerFailure extends TemporalFailure { | ||
constructor(message: string | undefined, public readonly nonRetryable: boolean, cause?: Error) { | ||
constructor( | ||
message: string | undefined, | ||
public readonly nonRetryable: boolean, | ||
cause?: Error | ||
) { | ||
super(message, cause); | ||
@@ -193,3 +200,7 @@ } | ||
export class CancelledFailure extends TemporalFailure { | ||
constructor(message: string | undefined, public readonly details: unknown[] = [], cause?: Error) { | ||
constructor( | ||
message: string | undefined, | ||
public readonly details: unknown[] = [], | ||
cause?: Error | ||
) { | ||
super(message, cause); | ||
@@ -196,0 +207,0 @@ } |
@@ -25,11 +25,11 @@ import type { Payload } from '../interfaces'; | ||
: [keyof T] extends [never] | ||
? T | ||
: T extends { [k: string]: ToReplace } | ||
? { | ||
[P in keyof T]: ReplaceNested<T[P], ToReplace, ReplaceWith>; | ||
} | ||
: T extends ToReplace | ||
? ReplaceWith | Exclude<T, ToReplace> | ||
: { | ||
[P in keyof T]: ReplaceNested<T[P], ToReplace, ReplaceWith>; | ||
}; | ||
? T | ||
: T extends { [k: string]: ToReplace } | ||
? { | ||
[P in keyof T]: ReplaceNested<T[P], ToReplace, ReplaceWith>; | ||
} | ||
: T extends ToReplace | ||
? ReplaceWith | Exclude<T, ToReplace> | ||
: { | ||
[P in keyof T]: ReplaceNested<T[P], ToReplace, ReplaceWith>; | ||
}; |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
No v1
QualityPackage is not semver >=1. This means it is not stable and does not support ^ ranges.
Found 1 instance in 1 package
380305
4
7347
0
1
+ Added@temporalio/proto@1.9.0(transitive)
+ Addedproto3-json-serializer@2.0.2(transitive)
- Removedprotobufjs@^7.2.5
- Removed@temporalio/proto@1.9.0-rc.0(transitive)
- Removedproto3-json-serializer@1.1.1(transitive)
Updated@temporalio/proto@1.9.0
Updatedlong@^5.2.3