Skip to content

Commit 6fc2d65

Browse files
committed
Merge remote-tracking branch 'origin/master' into fredtzeng/saa-on-conflict
2 parents 5f21385 + f224850 commit 6fc2d65

4 files changed

Lines changed: 39 additions & 6 deletions

File tree

openapi/openapiv2.json

Lines changed: 13 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1895,14 +1895,15 @@
18951895
},
18961896
{
18971897
"name": "taskQueue.kind",
1898-
"description": "Default: TASK_QUEUE_KIND_NORMAL.\n\n - TASK_QUEUE_KIND_UNSPECIFIED: Tasks from any non workflow task may be unspecified.\n\nTask queue kind is used to differentiate whether a workflow task queue is sticky or \nnormal. If a task is not a workflow task, Task queue kind will sometimes be \nunspecified.\n - TASK_QUEUE_KIND_NORMAL: Tasks from a normal workflow task queue always include complete workflow history\n\nThe task queue specified by the user is always a normal task queue. There can be as many\nworkers as desired for a single normal task queue. All those workers may pick up tasks from\nthat queue.\n - TASK_QUEUE_KIND_STICKY: A sticky queue only includes new history since the last workflow task, and they are\nper-worker.\n\nSticky queues are created dynamically by each worker during their start up. They only exist\nfor the lifetime of the worker process. Tasks in a sticky task queue are only available to\nthe worker that created the sticky queue.\n\nSticky queues are only for workflow tasks. There are no sticky task queues for activities.",
1898+
"description": "Default: TASK_QUEUE_KIND_NORMAL.\n\n - TASK_QUEUE_KIND_UNSPECIFIED: Tasks from any non workflow task may be unspecified.\n\nTask queue kind is used to differentiate whether a workflow task queue is sticky or \nnormal. If a task is not a workflow task, Task queue kind will sometimes be \nunspecified.\n - TASK_QUEUE_KIND_NORMAL: Tasks from a normal workflow task queue always include complete workflow history\n\nThe task queue specified by the user is always a normal task queue. There can be as many\nworkers as desired for a single normal task queue. All those workers may pick up tasks from\nthat queue.\n - TASK_QUEUE_KIND_STICKY: A sticky queue only includes new history since the last workflow task, and they are\nper-worker.\n\nSticky queues are created dynamically by each worker during their start up. They only exist\nfor the lifetime of the worker process. Tasks in a sticky task queue are only available to\nthe worker that created the sticky queue.\n\nSticky queues are only for workflow tasks. There are no sticky task queues for activities.\n - TASK_QUEUE_KIND_WORKER_COMMANDS: A worker-commands task queue is used for server-to-worker communication (e.g. activity\ncancellations). These queues are ephemeral and per-worker-process — they exist only for\nthe lifetime of the worker process. Used with TASK_QUEUE_TYPE_NEXUS and polled via\nPollNexusTaskQueue.",
18991899
"in": "query",
19001900
"required": false,
19011901
"type": "string",
19021902
"enum": [
19031903
"TASK_QUEUE_KIND_UNSPECIFIED",
19041904
"TASK_QUEUE_KIND_NORMAL",
1905-
"TASK_QUEUE_KIND_STICKY"
1905+
"TASK_QUEUE_KIND_STICKY",
1906+
"TASK_QUEUE_KIND_WORKER_COMMANDS"
19061907
],
19071908
"default": "TASK_QUEUE_KIND_UNSPECIFIED"
19081909
},
@@ -6632,14 +6633,15 @@
66326633
},
66336634
{
66346635
"name": "taskQueue.kind",
6635-
"description": "Default: TASK_QUEUE_KIND_NORMAL.\n\n - TASK_QUEUE_KIND_UNSPECIFIED: Tasks from any non workflow task may be unspecified.\n\nTask queue kind is used to differentiate whether a workflow task queue is sticky or \nnormal. If a task is not a workflow task, Task queue kind will sometimes be \nunspecified.\n - TASK_QUEUE_KIND_NORMAL: Tasks from a normal workflow task queue always include complete workflow history\n\nThe task queue specified by the user is always a normal task queue. There can be as many\nworkers as desired for a single normal task queue. All those workers may pick up tasks from\nthat queue.\n - TASK_QUEUE_KIND_STICKY: A sticky queue only includes new history since the last workflow task, and they are\nper-worker.\n\nSticky queues are created dynamically by each worker during their start up. They only exist\nfor the lifetime of the worker process. Tasks in a sticky task queue are only available to\nthe worker that created the sticky queue.\n\nSticky queues are only for workflow tasks. There are no sticky task queues for activities.",
6636+
"description": "Default: TASK_QUEUE_KIND_NORMAL.\n\n - TASK_QUEUE_KIND_UNSPECIFIED: Tasks from any non workflow task may be unspecified.\n\nTask queue kind is used to differentiate whether a workflow task queue is sticky or \nnormal. If a task is not a workflow task, Task queue kind will sometimes be \nunspecified.\n - TASK_QUEUE_KIND_NORMAL: Tasks from a normal workflow task queue always include complete workflow history\n\nThe task queue specified by the user is always a normal task queue. There can be as many\nworkers as desired for a single normal task queue. All those workers may pick up tasks from\nthat queue.\n - TASK_QUEUE_KIND_STICKY: A sticky queue only includes new history since the last workflow task, and they are\nper-worker.\n\nSticky queues are created dynamically by each worker during their start up. They only exist\nfor the lifetime of the worker process. Tasks in a sticky task queue are only available to\nthe worker that created the sticky queue.\n\nSticky queues are only for workflow tasks. There are no sticky task queues for activities.\n - TASK_QUEUE_KIND_WORKER_COMMANDS: A worker-commands task queue is used for server-to-worker communication (e.g. activity\ncancellations). These queues are ephemeral and per-worker-process — they exist only for\nthe lifetime of the worker process. Used with TASK_QUEUE_TYPE_NEXUS and polled via\nPollNexusTaskQueue.",
66366637
"in": "query",
66376638
"required": false,
66386639
"type": "string",
66396640
"enum": [
66406641
"TASK_QUEUE_KIND_UNSPECIFIED",
66416642
"TASK_QUEUE_KIND_NORMAL",
6642-
"TASK_QUEUE_KIND_STICKY"
6643+
"TASK_QUEUE_KIND_STICKY",
6644+
"TASK_QUEUE_KIND_WORKER_COMMANDS"
66436645
],
66446646
"default": "TASK_QUEUE_KIND_UNSPECIFIED"
66456647
},
@@ -16883,10 +16885,11 @@
1688316885
"enum": [
1688416886
"TASK_QUEUE_KIND_UNSPECIFIED",
1688516887
"TASK_QUEUE_KIND_NORMAL",
16886-
"TASK_QUEUE_KIND_STICKY"
16888+
"TASK_QUEUE_KIND_STICKY",
16889+
"TASK_QUEUE_KIND_WORKER_COMMANDS"
1688716890
],
1688816891
"default": "TASK_QUEUE_KIND_UNSPECIFIED",
16889-
"description": " - TASK_QUEUE_KIND_UNSPECIFIED: Tasks from any non workflow task may be unspecified.\n\nTask queue kind is used to differentiate whether a workflow task queue is sticky or \nnormal. If a task is not a workflow task, Task queue kind will sometimes be \nunspecified.\n - TASK_QUEUE_KIND_NORMAL: Tasks from a normal workflow task queue always include complete workflow history\n\nThe task queue specified by the user is always a normal task queue. There can be as many\nworkers as desired for a single normal task queue. All those workers may pick up tasks from\nthat queue.\n - TASK_QUEUE_KIND_STICKY: A sticky queue only includes new history since the last workflow task, and they are\nper-worker.\n\nSticky queues are created dynamically by each worker during their start up. They only exist\nfor the lifetime of the worker process. Tasks in a sticky task queue are only available to\nthe worker that created the sticky queue.\n\nSticky queues are only for workflow tasks. There are no sticky task queues for activities."
16892+
"description": " - TASK_QUEUE_KIND_UNSPECIFIED: Tasks from any non workflow task may be unspecified.\n\nTask queue kind is used to differentiate whether a workflow task queue is sticky or \nnormal. If a task is not a workflow task, Task queue kind will sometimes be \nunspecified.\n - TASK_QUEUE_KIND_NORMAL: Tasks from a normal workflow task queue always include complete workflow history\n\nThe task queue specified by the user is always a normal task queue. There can be as many\nworkers as desired for a single normal task queue. All those workers may pick up tasks from\nthat queue.\n - TASK_QUEUE_KIND_STICKY: A sticky queue only includes new history since the last workflow task, and they are\nper-worker.\n\nSticky queues are created dynamically by each worker during their start up. They only exist\nfor the lifetime of the worker process. Tasks in a sticky task queue are only available to\nthe worker that created the sticky queue.\n\nSticky queues are only for workflow tasks. There are no sticky task queues for activities.\n - TASK_QUEUE_KIND_WORKER_COMMANDS: A worker-commands task queue is used for server-to-worker communication (e.g. activity\ncancellations). These queues are ephemeral and per-worker-process — they exist only for\nthe lifetime of the worker process. Used with TASK_QUEUE_TYPE_NEXUS and polled via\nPollNexusTaskQueue."
1689016893
},
1689116894
"v1TaskQueueReachability": {
1689216895
"type": "object",
@@ -18647,6 +18650,10 @@
1864718650
"declinedTargetVersionUpgrade": {
1864818651
"$ref": "#/definitions/v1DeclinedTargetVersionUpgrade",
1864918652
"description": "During a previous run of this workflow, the server may have notified the SDK\nthat the Target Worker Deployment Version changed, but the SDK declined to\nupgrade (e.g., by continuing-as-new with PINNED behavior). This field records\nthe target version that was declined.\n\nThis is a wrapper message to distinguish \"never declined\" (nil wrapper) from\n\"declined an unversioned target\" (non-nil wrapper with nil deployment_version).\n\nUsed internally by the server during continue-as-new and retry.\nShould not be read or interpreted by SDKs."
18653+
},
18654+
"timeSkippingConfig": {
18655+
"$ref": "#/definitions/v1TimeSkippingConfig",
18656+
"description": "Initial time-skipping configuration for this workflow execution, recorded at start time.\nThis may have been set explicitly via the start workflow request, or propagated from a\nparent/previous execution.\n\nThe configuration may be updated after start via UpdateWorkflowExecutionOptions, which\nwill be reflected in the WorkflowExecutionOptionsUpdatedEvent."
1865018657
}
1865118658
},
1865218659
"title": "Always the first event in workflow history"

openapi/openapiv3.yaml

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1812,6 +1812,7 @@ paths:
18121812
- TASK_QUEUE_KIND_UNSPECIFIED
18131813
- TASK_QUEUE_KIND_NORMAL
18141814
- TASK_QUEUE_KIND_STICKY
1815+
- TASK_QUEUE_KIND_WORKER_COMMANDS
18151816
type: string
18161817
format: enum
18171818
- name: taskQueue.normalName
@@ -6046,6 +6047,7 @@ paths:
60466047
- TASK_QUEUE_KIND_UNSPECIFIED
60476048
- TASK_QUEUE_KIND_NORMAL
60486049
- TASK_QUEUE_KIND_STICKY
6050+
- TASK_QUEUE_KIND_WORKER_COMMANDS
60496051
type: string
60506052
format: enum
60516053
- name: taskQueue.normalName
@@ -14790,6 +14792,7 @@ components:
1479014792
- TASK_QUEUE_KIND_UNSPECIFIED
1479114793
- TASK_QUEUE_KIND_NORMAL
1479214794
- TASK_QUEUE_KIND_STICKY
14795+
- TASK_QUEUE_KIND_WORKER_COMMANDS
1479314796
type: string
1479414797
description: 'Default: TASK_QUEUE_KIND_NORMAL.'
1479514798
format: enum
@@ -17358,6 +17361,16 @@ components:
1735817361

1735917362
Used internally by the server during continue-as-new and retry.
1736017363
Should not be read or interpreted by SDKs.
17364+
timeSkippingConfig:
17365+
allOf:
17366+
- $ref: '#/components/schemas/TimeSkippingConfig'
17367+
description: |-
17368+
Initial time-skipping configuration for this workflow execution, recorded at start time.
17369+
This may have been set explicitly via the start workflow request, or propagated from a
17370+
parent/previous execution.
17371+
17372+
The configuration may be updated after start via UpdateWorkflowExecutionOptions, which
17373+
will be reflected in the WorkflowExecutionOptionsUpdatedEvent.
1736117374
description: Always the first event in workflow history
1736217375
WorkflowExecutionTerminatedEventAttributes:
1736317376
type: object

temporal/api/enums/v1/task_queue.proto

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,11 @@ enum TaskQueueKind {
3131
//
3232
// Sticky queues are only for workflow tasks. There are no sticky task queues for activities.
3333
TASK_QUEUE_KIND_STICKY = 2;
34+
// A worker-commands task queue is used for server-to-worker communication (e.g. activity
35+
// cancellations). These queues are ephemeral and per-worker-process — they exist only for
36+
// the lifetime of the worker process. Used with TASK_QUEUE_TYPE_NEXUS and polled via
37+
// PollNexusTaskQueue.
38+
TASK_QUEUE_KIND_WORKER_COMMANDS = 3;
3439
}
3540

3641
enum TaskQueueType {

temporal/api/history/v1/message.proto

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -196,6 +196,14 @@ message WorkflowExecutionStartedEventAttributes {
196196
// Used internally by the server during continue-as-new and retry.
197197
// Should not be read or interpreted by SDKs.
198198
DeclinedTargetVersionUpgrade declined_target_version_upgrade = 40;
199+
200+
// Initial time-skipping configuration for this workflow execution, recorded at start time.
201+
// This may have been set explicitly via the start workflow request, or propagated from a
202+
// parent/previous execution.
203+
//
204+
// The configuration may be updated after start via UpdateWorkflowExecutionOptions, which
205+
// will be reflected in the WorkflowExecutionOptionsUpdatedEvent.
206+
temporal.api.workflow.v1.TimeSkippingConfig time_skipping_config = 41;
199207
}
200208

201209
// Wrapper for a target deployment version that the SDK declined to upgrade to.

0 commit comments

Comments
 (0)