Skip to content

Update core and update Rust dependencies #337

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 2 commits into from
Jul 5, 2023
Merged

Update core and update Rust dependencies #337

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
ba3d8e8
Update core and update Rust dependencies
cretz Jul 5, 2023
80e246d
Regen protos
cretz Jul 5, 2023
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 scripts/gen_protos.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@
for v in proto_dir.glob("**/*.proto")
if not str(v).startswith(str(testsrv_proto_dir / "dependencies"))
and not "health" in str(v)
and not "google" in str(v)
]
proto_paths.extend(test_proto_dir.glob("**/*.proto"))
proto_paths.extend(additional_proto_dir.glob("**/*.proto"))
Expand Down
2 changes: 2 additions & 0 deletions temporalio/api/batch/v1/__init__.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@
BatchOperationCancellation,
BatchOperationDeletion,
BatchOperationInfo,
BatchOperationReset,
BatchOperationSignal,
BatchOperationTermination,
)
Expand All @@ -10,6 +11,7 @@
"BatchOperationCancellation",
"BatchOperationDeletion",
"BatchOperationInfo",
"BatchOperationReset",
"BatchOperationSignal",
"BatchOperationTermination",
]
39 changes: 28 additions & 11 deletions temporalio/api/batch/v1/message_pb2.py
View file
Open in desktop

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

38 changes: 38 additions & 0 deletions temporalio/api/batch/v1/message_pb2.pyi
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,7 @@ import google.protobuf.timestamp_pb2
import sys
import temporalio.api.common.v1.message_pb2
import temporalio.api.enums.v1.batch_operation_pb2
import temporalio.api.enums.v1.reset_pb2

if sys.version_info >= (3, 8):
import typing as typing_extensions
Expand Down Expand Up @@ -211,3 +212,40 @@ class BatchOperationDeletion(google.protobuf.message.Message):
) -> None: ...

global___BatchOperationDeletion = BatchOperationDeletion

class BatchOperationReset(google.protobuf.message.Message):
"""BatchOperationReset sends reset requests to batch workflows.
Keep the parameter in sync with temporalio.api.workflowservice.v1.ResetWorkflowExecutionRequest.
"""

DESCRIPTOR: google.protobuf.descriptor.Descriptor

RESET_TYPE_FIELD_NUMBER: builtins.int
RESET_REAPPLY_TYPE_FIELD_NUMBER: builtins.int
IDENTITY_FIELD_NUMBER: builtins.int
reset_type: temporalio.api.enums.v1.reset_pb2.ResetType.ValueType
"""Reset type."""
reset_reapply_type: temporalio.api.enums.v1.reset_pb2.ResetReapplyType.ValueType
"""History event reapply options."""
identity: builtins.str
"""The identity of the worker/client."""
def __init__(
self,
*,
reset_type: temporalio.api.enums.v1.reset_pb2.ResetType.ValueType = ...,
reset_reapply_type: temporalio.api.enums.v1.reset_pb2.ResetReapplyType.ValueType = ...,
identity: builtins.str = ...,
) -> None: ...
def ClearField(
self,
field_name: typing_extensions.Literal[
"identity",
b"identity",
"reset_reapply_type",
b"reset_reapply_type",
"reset_type",
b"reset_type",
],
) -> None: ...

global___BatchOperationReset = BatchOperationReset
68 changes: 34 additions & 34 deletions temporalio/api/command/v1/message_pb2.py
View file
Open in desktop

Large diffs are not rendered by default.

26 changes: 26 additions & 0 deletions temporalio/api/command/v1/message_pb2.pyi
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,7 @@ class ScheduleActivityTaskCommandAttributes(google.protobuf.message.Message):
HEARTBEAT_TIMEOUT_FIELD_NUMBER: builtins.int
RETRY_POLICY_FIELD_NUMBER: builtins.int
REQUEST_EAGER_EXECUTION_FIELD_NUMBER: builtins.int
USE_COMPATIBLE_VERSION_FIELD_NUMBER: builtins.int
activity_id: builtins.str
@property
def activity_type(self) -> temporalio.api.common.v1.message_pb2.ActivityType: ...
Expand Down Expand Up @@ -110,6 +111,11 @@ class ScheduleActivityTaskCommandAttributes(google.protobuf.message.Message):
"""Request to start the activity directly bypassing matching service and worker polling
The slot for executing the activity should be reserved when setting this field to true.
"""
use_compatible_version: builtins.bool
"""If this is set, the workflow executing this command wishes to start the activity using
a version compatible with the version that this workflow most recently ran on, if such
behavior is possible.
"""
def __init__(
self,
*,
Expand All @@ -124,6 +130,7 @@ class ScheduleActivityTaskCommandAttributes(google.protobuf.message.Message):
heartbeat_timeout: google.protobuf.duration_pb2.Duration | None = ...,
retry_policy: temporalio.api.common.v1.message_pb2.RetryPolicy | None = ...,
request_eager_execution: builtins.bool = ...,
use_compatible_version: builtins.bool = ...,
) -> None: ...
def HasField(
self,
Expand Down Expand Up @@ -173,6 +180,8 @@ class ScheduleActivityTaskCommandAttributes(google.protobuf.message.Message):
b"start_to_close_timeout",
"task_queue",
b"task_queue",
"use_compatible_version",
b"use_compatible_version",
],
) -> None: ...

Expand Down Expand Up @@ -591,6 +600,7 @@ class ContinueAsNewWorkflowExecutionCommandAttributes(google.protobuf.message.Me
HEADER_FIELD_NUMBER: builtins.int
MEMO_FIELD_NUMBER: builtins.int
SEARCH_ATTRIBUTES_FIELD_NUMBER: builtins.int
USE_COMPATIBLE_VERSION_FIELD_NUMBER: builtins.int
@property
def workflow_type(self) -> temporalio.api.common.v1.message_pb2.WorkflowType: ...
@property
Expand Down Expand Up @@ -626,6 +636,10 @@ class ContinueAsNewWorkflowExecutionCommandAttributes(google.protobuf.message.Me
def search_attributes(
self,
) -> temporalio.api.common.v1.message_pb2.SearchAttributes: ...
use_compatible_version: builtins.bool
"""If this is set, the workflow executing this command wishes to continue as new using a version
compatible with the version that this workflow most recently ran on.
"""
def __init__(
self,
*,
Expand All @@ -645,6 +659,7 @@ class ContinueAsNewWorkflowExecutionCommandAttributes(google.protobuf.message.Me
memo: temporalio.api.common.v1.message_pb2.Memo | None = ...,
search_attributes: temporalio.api.common.v1.message_pb2.SearchAttributes
| None = ...,
use_compatible_version: builtins.bool = ...,
) -> None: ...
def HasField(
self,
Expand Down Expand Up @@ -700,6 +715,8 @@ class ContinueAsNewWorkflowExecutionCommandAttributes(google.protobuf.message.Me
b"search_attributes",
"task_queue",
b"task_queue",
"use_compatible_version",
b"use_compatible_version",
"workflow_run_timeout",
b"workflow_run_timeout",
"workflow_task_timeout",
Expand Down Expand Up @@ -732,6 +749,7 @@ class StartChildWorkflowExecutionCommandAttributes(google.protobuf.message.Messa
HEADER_FIELD_NUMBER: builtins.int
MEMO_FIELD_NUMBER: builtins.int
SEARCH_ATTRIBUTES_FIELD_NUMBER: builtins.int
USE_COMPATIBLE_VERSION_FIELD_NUMBER: builtins.int
namespace: builtins.str
workflow_id: builtins.str
@property
Expand Down Expand Up @@ -766,6 +784,11 @@ class StartChildWorkflowExecutionCommandAttributes(google.protobuf.message.Messa
def search_attributes(
self,
) -> temporalio.api.common.v1.message_pb2.SearchAttributes: ...
use_compatible_version: builtins.bool
"""If this is set, the workflow executing this command wishes to start the child workflow using
a version compatible with the version that this workflow most recently ran on, if such
behavior is possible.
"""
def __init__(
self,
*,
Expand All @@ -786,6 +809,7 @@ class StartChildWorkflowExecutionCommandAttributes(google.protobuf.message.Messa
memo: temporalio.api.common.v1.message_pb2.Memo | None = ...,
search_attributes: temporalio.api.common.v1.message_pb2.SearchAttributes
| None = ...,
use_compatible_version: builtins.bool = ...,
) -> None: ...
def HasField(
self,
Expand Down Expand Up @@ -835,6 +859,8 @@ class StartChildWorkflowExecutionCommandAttributes(google.protobuf.message.Messa
b"search_attributes",
"task_queue",
b"task_queue",
"use_compatible_version",
b"use_compatible_version",
"workflow_execution_timeout",
b"workflow_execution_timeout",
"workflow_id",
Expand Down
8 changes: 4 additions & 4 deletions temporalio/api/common/v1/message_pb2.py
View file
Open in desktop

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

Loading