Class: PollActivityTaskQueueResponse
Represents a PollActivityTaskQueueResponse.
Properties
activityId
activityId:
string
The autogenerated or user specified identifier of this activity. Can be used to complete the
activity via RespondActivityTaskCompletedById. May be re-used as long as the last usage
has resolved, but unique IDs for every activity invocation is a good idea.
Note that only a workflow activity ID may be autogenerated.
activityRunId
activityRunId:
string
The run ID of the activity execution, only set for standalone activities.
activityType?
optionalactivityType?:$Properties|null
PollActivityTaskQueueResponse activityType.
attempt
attempt:
number
Starting at 1, the number of attempts to perform this activity
currentAttemptScheduledTime?
optionalcurrentAttemptScheduledTime?:$Properties|null
When was this task attempt scheduled
header?
optionalheader?:$Properties|null
Headers specified by the scheduling workflow. Commonly used to propagate contextual info from the workflow to its activities. For example, tracing contexts.
heartbeatDetails?
optionalheartbeatDetails?:$Properties|null
Details of the last heartbeat that was recorded for this activity as of the time this task was delivered.
heartbeatTimeout?
optionalheartbeatTimeout?:$Properties|null
Window within which the activity must report a heartbeat, or be timed out.
input?
optionalinput?:$Properties|null
Arguments to the activity invocation
pollerGroupInfos
pollerGroupInfos:
$Properties[]
The weighted list of poller groups IDs that client should use for future polls to this task queue. Client is expected to:
- Maintain minimum number of pollers no less than the number of groups.
- Try to assign the next poll to a group without any pending polls,
- If every group has some pending polls, assign the next poll to a group randomly according to the weights.
pollerGroupsInfo?
optionalpollerGroupsInfo?:$Properties|null
The weighted, versioned list of poller groups IDs that client should use for future polls to
this task queue. Client should ignore this if it has already applied a snapshot with a
version greater than or equal to poller_groups_info.version. Client is expected to:
- Maintain minimum number of pollers no less than the number of groups.
- Try to assign the next poll to a group without any pending polls,
- If every group has some pending polls, assign the next poll to a group randomly according to the weights.
pollerScalingDecision?
optionalpollerScalingDecision?:$Properties|null
Server-advised information the SDK may use to adjust its poller count.
priority?
optionalpriority?:$Properties|null
Priority metadata
propagatedNexusSerializationContext?
optionalpropagatedNexusSerializationContext?:$Properties|null
Serialization context propagated from the Nexus caller that started this activity.
retryPolicy?
optionalretryPolicy?:$Properties|null
This is the retry policy the service uses which may be different from the one provided (or not) during activity scheduling. The service can override the provided one if some values are not specified or exceed configured system limits.
scheduledTime?
optionalscheduledTime?:$Properties|null
When was this task first scheduled
scheduleToCloseTimeout?
optionalscheduleToCloseTimeout?:$Properties|null
First scheduled -> final result reported timeout
(-- api-linter: core::0140::prepositions=disabled aip.dev/not-precedent: "to" is used to indicate interval. --)
startedTime?
optionalstartedTime?:$Properties|null
When was this task started (this attempt)
startToCloseTimeout?
optionalstartToCloseTimeout?:$Properties|null
Current attempt start -> final result reported timeout
(-- api-linter: core::0140::prepositions=disabled aip.dev/not-precedent: "to" is used to indicate interval. --)
taskToken
taskToken:
Uint8Array
A unique identifier for this task
workflowExecution?
optionalworkflowExecution?:$Properties|null
Execution info of the requesting workflow (if this is a workflow activity)
workflowNamespace
workflowNamespace:
string
The namespace of the activity. If this is a workflow activity then this is the namespace of the workflow also. If this is a standalone activity then the name of this field is misleading, but retained for compatibility with workflow activities.
workflowType?
optionalworkflowType?:$Properties|null
Type of the requesting workflow (if this is a workflow activity).
Methods
toJSON()
toJSON():
object
Converts this PollActivityTaskQueueResponse to JSON.
Returns
object
JSON object
create()
Call Signature
staticcreate(properties?):PollActivityTaskQueueResponse&$Properties
Creates a new PollActivityTaskQueueResponse instance using the specified properties.
Parameters
properties?
Properties to set
Returns
PollActivityTaskQueueResponse & $Properties
PollActivityTaskQueueResponse instance
Call Signature
staticcreate(properties?):PollActivityTaskQueueResponse
Creates a new PollActivityTaskQueueResponse instance using the specified properties.
Parameters
properties?
Properties to set
Returns
PollActivityTaskQueueResponse
PollActivityTaskQueueResponse instance
decode()
staticdecode(reader,length?):PollActivityTaskQueueResponse&$Properties
Decodes a PollActivityTaskQueueResponse message from the specified reader or buffer.
Parameters
reader
Uint8Array<ArrayBufferLike> | Reader
Reader or buffer to decode from
length?
number
Message length if known beforehand
Returns
PollActivityTaskQueueResponse & $Properties
PollActivityTaskQueueResponse
Throws
If the payload is not a reader or valid buffer
Throws
If required fields are missing
decodeDelimited()
staticdecodeDelimited(reader):PollActivityTaskQueueResponse&$Properties
Decodes a PollActivityTaskQueueResponse message from the specified reader or buffer, length delimited.
Parameters
reader
Uint8Array<ArrayBufferLike> | Reader
Reader or buffer to decode from
Returns
PollActivityTaskQueueResponse & $Properties
PollActivityTaskQueueResponse
Throws
If the payload is not a reader or valid buffer
Throws
If required fields are missing
encode()
staticencode(message,writer?):Writer
Encodes the specified PollActivityTaskQueueResponse message. Does not implicitly temporal.api.workflowservice.v1.PollActivityTaskQueueResponse.verify|verify messages.
Parameters
message
PollActivityTaskQueueResponse message or plain object to encode
writer?
Writer
Writer to encode to
Returns
Writer
Writer
encodeDelimited()
staticencodeDelimited(message,writer?):Writer
Encodes the specified PollActivityTaskQueueResponse message, length delimited. Does not implicitly temporal.api.workflowservice.v1.PollActivityTaskQueueResponse.verify|verify messages.
Parameters
message
PollActivityTaskQueueResponse message or plain object to encode
writer?
Writer
Writer to encode to
Returns
Writer
Writer
fromObject()
staticfromObject(object):PollActivityTaskQueueResponse
Creates a PollActivityTaskQueueResponse message from a plain object. Also converts values to their respective internal types.
Parameters
object
Plain object
Returns
PollActivityTaskQueueResponse
PollActivityTaskQueueResponse
toObject()
statictoObject(message,options?):object
Creates a plain object from a PollActivityTaskQueueResponse message. Also converts values to other types if specified.
Parameters
message
PollActivityTaskQueueResponse
PollActivityTaskQueueResponse
options?
IConversionOptions
Conversion options
Returns
object
Plain object