@temporalio/workflow
Advanced tools
Comparing version
/// <reference types="node" /> | ||
import type { AsyncLocalStorage as ALS } from 'async_hooks'; | ||
import type { AsyncLocalStorage as ALS } from 'node:async_hooks'; | ||
export declare const AsyncLocalStorage: new <T>() => ALS<T>; | ||
@@ -4,0 +4,0 @@ /** Magic symbol used to create the root scope - intentionally not exported */ |
@@ -8,3 +8,3 @@ /** | ||
/** | ||
* Thrown in workflow when it tries to do something that non-deterministic such as construct a WeakMap() | ||
* Thrown in workflow when it tries to do something that non-deterministic such as construct a WeakRef() | ||
*/ | ||
@@ -11,0 +11,0 @@ export declare class DeterminismViolationError extends WorkflowError { |
@@ -15,3 +15,3 @@ "use strict"; | ||
/** | ||
* Thrown in workflow when it tries to do something that non-deterministic such as construct a WeakMap() | ||
* Thrown in workflow when it tries to do something that non-deterministic such as construct a WeakRef() | ||
*/ | ||
@@ -18,0 +18,0 @@ class DeterminismViolationError extends WorkflowError { |
@@ -20,3 +20,2 @@ "use strict"; | ||
// Mock any weak reference because GC is non-deterministic and the effect is observable from the Workflow. | ||
// WeakRef is implemented in V8 8.4 which is embedded in node >=14.6.0. | ||
// Workflow developer will get a meaningful exception if they try to use these. | ||
@@ -23,0 +22,0 @@ global.WeakRef = function () { |
@@ -356,3 +356,3 @@ import { ActivityFunction, ActivityOptions, LocalActivityOptions, QueryDefinition, SearchAttributes, SignalDefinition, UntypedActivities, WithWorkflowArgs, Workflow, WorkflowResultType, WorkflowReturnType } from '@temporalio/common'; | ||
*/ | ||
export declare function defineSignal<Args extends any[] = []>(name: string): SignalDefinition<Args>; | ||
export declare function defineSignal<Args extends any[] = [], Name extends string = string>(name: Name): SignalDefinition<Args, Name>; | ||
/** | ||
@@ -364,3 +364,3 @@ * Define a query method for a Workflow. | ||
*/ | ||
export declare function defineQuery<Ret, Args extends any[] = []>(name: string): QueryDefinition<Ret, Args>; | ||
export declare function defineQuery<Ret, Args extends any[] = [], Name extends string = string>(name: Name): QueryDefinition<Ret, Args, Name>; | ||
/** | ||
@@ -415,3 +415,3 @@ * Set a handler function for a Workflow query or signal. | ||
export declare function upsertSearchAttributes(searchAttributes: SearchAttributes): void; | ||
export declare const stackTraceQuery: QueryDefinition<string, []>; | ||
export declare const enhancedStackTraceQuery: QueryDefinition<EnhancedStackTrace, []>; | ||
export declare const stackTraceQuery: QueryDefinition<string, [], string>; | ||
export declare const enhancedStackTraceQuery: QueryDefinition<EnhancedStackTrace, [], string>; |
{ | ||
"name": "@temporalio/workflow", | ||
"version": "1.6.0", | ||
"version": "1.7.0", | ||
"description": "Temporal.io SDK Workflow sub-package", | ||
@@ -10,6 +10,11 @@ "keywords": [ | ||
], | ||
"homepage": "https://github.com/temporalio/sdk-typescript/tree/main/packages/workflow", | ||
"bugs": { | ||
"url": "https://github.com/temporalio/sdk-typescript/issues" | ||
}, | ||
"repository": { | ||
"type": "git", | ||
"url": "git+https://github.com/temporalio/sdk-typescript.git", | ||
"directory": "packages/workflow" | ||
}, | ||
"homepage": "https://github.com/temporalio/sdk-typescript/tree/main/packages/workflow", | ||
"license": "MIT", | ||
@@ -21,4 +26,4 @@ "author": "Temporal Technologies Inc. <sdk@temporal.io>", | ||
"dependencies": { | ||
"@temporalio/common": "1.6.0", | ||
"@temporalio/proto": "1.6.0" | ||
"@temporalio/common": "1.7.0", | ||
"@temporalio/proto": "1.7.0" | ||
}, | ||
@@ -35,3 +40,3 @@ "devDependencies": { | ||
], | ||
"gitHead": "49c6b1341daef2b94a0a989d515cbf97b8b02fa7" | ||
"gitHead": "2b32bac62f879b35238b487d3aaed093a1e449a7" | ||
} |
@@ -1,2 +0,2 @@ | ||
import type { AsyncLocalStorage as ALS } from 'async_hooks'; | ||
import type { AsyncLocalStorage as ALS } from 'node:async_hooks'; | ||
import { CancelledFailure, IllegalStateError } from '@temporalio/common'; | ||
@@ -3,0 +3,0 @@ import { untrackPromise } from './stack-helpers'; |
@@ -9,3 +9,3 @@ /** | ||
/** | ||
* Thrown in workflow when it tries to do something that non-deterministic such as construct a WeakMap() | ||
* Thrown in workflow when it tries to do something that non-deterministic such as construct a WeakRef() | ||
*/ | ||
@@ -12,0 +12,0 @@ export class DeterminismViolationError extends WorkflowError { |
@@ -26,3 +26,2 @@ /** | ||
// Mock any weak reference because GC is non-deterministic and the effect is observable from the Workflow. | ||
// WeakRef is implemented in V8 8.4 which is embedded in node >=14.6.0. | ||
// Workflow developer will get a meaningful exception if they try to use these. | ||
@@ -29,0 +28,0 @@ global.WeakRef = function () { |
@@ -697,3 +697,3 @@ import { | ||
const activator = getActivator(); | ||
const optionsWithDefaults = addDefaultWorkflowOptions(options ?? {}); | ||
const optionsWithDefaults = addDefaultWorkflowOptions(options ?? ({} as any)); | ||
const workflowType = typeof workflowTypeOrFunc === 'string' ? workflowTypeOrFunc : workflowTypeOrFunc.name; | ||
@@ -797,3 +797,3 @@ const execute = composeInterceptors( | ||
const activator = getActivator(); | ||
const optionsWithDefaults = addDefaultWorkflowOptions(options ?? {}); | ||
const optionsWithDefaults = addDefaultWorkflowOptions(options ?? ({} as any)); | ||
const workflowType = typeof workflowTypeOrFunc === 'string' ? workflowTypeOrFunc : workflowTypeOrFunc.name; | ||
@@ -1127,7 +1127,9 @@ const execute = composeInterceptors( | ||
*/ | ||
export function defineSignal<Args extends any[] = []>(name: string): SignalDefinition<Args> { | ||
export function defineSignal<Args extends any[] = [], Name extends string = string>( | ||
name: Name | ||
): SignalDefinition<Args, Name> { | ||
return { | ||
type: 'signal', | ||
name, | ||
}; | ||
} as SignalDefinition<Args, Name>; | ||
} | ||
@@ -1141,7 +1143,9 @@ | ||
*/ | ||
export function defineQuery<Ret, Args extends any[] = []>(name: string): QueryDefinition<Ret, Args> { | ||
export function defineQuery<Ret, Args extends any[] = [], Name extends string = string>( | ||
name: Name | ||
): QueryDefinition<Ret, Args, Name> { | ||
return { | ||
type: 'query', | ||
name, | ||
}; | ||
} as QueryDefinition<Ret, Args, Name>; | ||
} | ||
@@ -1148,0 +1152,0 @@ |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
No repository
Supply chain riskPackage does not have a linked source code repository. Without this field, a package will have no reference to the location of the source code use to generate the package.
Found 1 instance in 1 package
335126
0.07%7143
0.03%0
-100%+ Added
+ Added
- Removed
- Removed
Updated
Updated