Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions temporalio/bridge/Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
Expand Up @@ -93,6 +93,7 @@ class WorkflowActivation(google.protobuf.message.Message):
CONTINUE_AS_NEW_SUGGESTED_FIELD_NUMBER: builtins.int
DEPLOYMENT_VERSION_FOR_CURRENT_TASK_FIELD_NUMBER: builtins.int
LAST_SDK_VERSION_FIELD_NUMBER: builtins.int
SUGGEST_CONTINUE_AS_NEW_REASONS_FIELD_NUMBER: builtins.int
run_id: builtins.str
"""The id of the currently active run of the workflow. Also used as a cache key. There may
only ever be one active workflow task (and hence activation) of a run at one time.
Expand Down Expand Up @@ -139,6 +140,16 @@ class WorkflowActivation(google.protobuf.message.Message):
"""
last_sdk_version: builtins.str
"""The last seen SDK version from the most recent WFT completed event"""
@property
def suggest_continue_as_new_reasons(
self,
) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[
temporalio.api.enums.v1.workflow_pb2.SuggestContinueAsNewReason.ValueType
]:
"""Experimental. Optionally decide the versioning behavior that the first task of the new run should use.
For example, choose to AutoUpgrade on continue-as-new instead of inheriting the pinned version
of the previous run.
"""
def __init__(
self,
*,
Expand All @@ -153,6 +164,10 @@ class WorkflowActivation(google.protobuf.message.Message):
deployment_version_for_current_task: temporalio.bridge.proto.common.common_pb2.WorkerDeploymentVersion
| None = ...,
last_sdk_version: builtins.str = ...,
suggest_continue_as_new_reasons: collections.abc.Iterable[
temporalio.api.enums.v1.workflow_pb2.SuggestContinueAsNewReason.ValueType
]
| None = ...,
) -> None: ...
def HasField(
self,
Expand Down Expand Up @@ -184,6 +199,8 @@ class WorkflowActivation(google.protobuf.message.Message):
b"last_sdk_version",
"run_id",
b"run_id",
"suggest_continue_as_new_reasons",
b"suggest_continue_as_new_reasons",
"timestamp",
b"timestamp",
],
Expand Down

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
Expand Up @@ -963,6 +963,7 @@ class ContinueAsNewWorkflowExecution(google.protobuf.message.Message):
SEARCH_ATTRIBUTES_FIELD_NUMBER: builtins.int
RETRY_POLICY_FIELD_NUMBER: builtins.int
VERSIONING_INTENT_FIELD_NUMBER: builtins.int
INITIAL_VERSIONING_BEHAVIOR_FIELD_NUMBER: builtins.int
workflow_type: builtins.str
"""The identifier the lang-specific sdk uses to execute workflow code"""
task_queue: builtins.str
Expand Down Expand Up @@ -1016,6 +1017,13 @@ class ContinueAsNewWorkflowExecution(google.protobuf.message.Message):
temporalio.bridge.proto.common.common_pb2.VersioningIntent.ValueType
)
"""Whether the continued workflow should run on a worker with a compatible build id or not."""
initial_versioning_behavior: (
temporalio.api.enums.v1.workflow_pb2.ContinueAsNewVersioningBehavior.ValueType
)
"""Experimental. Optionally decide the versioning behavior that the first task of the new run should use.
For example, choose to AutoUpgrade on continue-as-new instead of inheriting the pinned version
of the previous run.
"""
def __init__(
self,
*,
Expand All @@ -1041,6 +1049,7 @@ class ContinueAsNewWorkflowExecution(google.protobuf.message.Message):
| None = ...,
retry_policy: temporalio.api.common.v1.message_pb2.RetryPolicy | None = ...,
versioning_intent: temporalio.bridge.proto.common.common_pb2.VersioningIntent.ValueType = ...,
initial_versioning_behavior: temporalio.api.enums.v1.workflow_pb2.ContinueAsNewVersioningBehavior.ValueType = ...,
) -> None: ...
def HasField(
self,
Expand All @@ -1060,6 +1069,8 @@ class ContinueAsNewWorkflowExecution(google.protobuf.message.Message):
b"arguments",
"headers",
b"headers",
"initial_versioning_behavior",
b"initial_versioning_behavior",
"memo",
b"memo",
"retry_policy",
Expand Down
2 changes: 1 addition & 1 deletion temporalio/bridge/sdk-core