Interface: WorkflowOutboundCallsInterceptor
workflow.WorkflowOutboundCallsInterceptor
Implement any of these methods to intercept Workflow code calls to the Temporal APIs, like scheduling an activity and starting a timer
Implemented by
Properties
continueAsNew
• Optional
continueAsNew: (input
: ContinueAsNewInput
, next
: OmitLastParam
<(input: ContinueAsNewInput, next: OmitLastParam<...>) => Promise<never>>) => Promise
<never
>
Called when Workflow calls continueAsNew
Type declaration
▸ (input
, next
): Promise
<never
>
Called when Workflow calls continueAsNew
Parameters
Name | Type |
---|---|
input | ContinueAsNewInput |
next | OmitLastParam <(input: ContinueAsNewInput, next: OmitLastParam<...>) => Promise<never>> |
Returns
Promise
<never
>
getLogAttributes
• Optional
getLogAttributes: (input
: GetLogAttributesInput
, next
: OmitLastParam
<(input: GetLogAttributesInput, next: OmitLastParam<...>) => Record<string, unknown>>) => Record
<string
, unknown
>
Called on each invocation of the workflow.log
methods.
The attributes returned in this call are attached to every log message.
Type declaration
▸ (input
, next
): Record
<string
, unknown
>
Called on each invocation of the workflow.log
methods.
The attributes returned in this call are attached to every log message.
Parameters
Name | Type |
---|---|
input | GetLogAttributesInput |
next | OmitLastParam <(input: GetLogAttributesInput, next: OmitLastParam<...>) => Record<string, unknown>> |
Returns
Record
<string
, unknown
>
scheduleActivity
• Optional
scheduleActivity: (input
: ActivityInput
, next
: OmitLastParam
<(input: ActivityInput, next: OmitLastParam<...>) => Promise<unknown>>) => Promise
<unknown
>
Called when Workflow schedules an Activity
Type declaration
▸ (input
, next
): Promise
<unknown
>
Called when Workflow schedules an Activity
Parameters
Name | Type |
---|---|
input | ActivityInput |
next | OmitLastParam <(input: ActivityInput, next: OmitLastParam<...>) => Promise<unknown>> |
Returns
Promise
<unknown
>
result of the activity execution