Skip to content

Commit

Permalink
Merge remote-tracking branch 'remotes/origin/main' into log-forwarding-2
Browse files Browse the repository at this point in the history
  • Loading branch information
cretz committed Nov 3, 2023
2 parents 67907c6 + 063b9bf commit 07f7cdc
Show file tree
Hide file tree
Showing 15 changed files with 1,536 additions and 371 deletions.
124 changes: 62 additions & 62 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 @@ -45,6 +45,7 @@ class WorkflowActivation(google.protobuf.message.Message):
AVAILABLE_INTERNAL_FLAGS_FIELD_NUMBER: builtins.int
HISTORY_SIZE_BYTES_FIELD_NUMBER: builtins.int
CONTINUE_AS_NEW_SUGGESTED_FIELD_NUMBER: builtins.int
BUILD_ID_FOR_CURRENT_TASK_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 @@ -77,6 +78,11 @@ class WorkflowActivation(google.protobuf.message.Message):
"""The history size in bytes as of the last WFT started event"""
continue_as_new_suggested: builtins.bool
"""Set true if the most recent WFT started event had this suggestion"""
build_id_for_current_task: builtins.str
"""Set to the Build ID of the worker that processed this task, which may be empty. During replay
this id may not equal the id of the replaying worker. If not replaying and this worker has
a defined Build ID, it will equal that ID. It will also be empty for evict-only activations.
"""
def __init__(
self,
*,
Expand All @@ -88,6 +94,7 @@ class WorkflowActivation(google.protobuf.message.Message):
available_internal_flags: collections.abc.Iterable[builtins.int] | None = ...,
history_size_bytes: builtins.int = ...,
continue_as_new_suggested: builtins.bool = ...,
build_id_for_current_task: builtins.str = ...,
) -> None: ...
def HasField(
self, field_name: typing_extensions.Literal["timestamp", b"timestamp"]
Expand All @@ -97,6 +104,8 @@ class WorkflowActivation(google.protobuf.message.Message):
field_name: typing_extensions.Literal[
"available_internal_flags",
b"available_internal_flags",
"build_id_for_current_task",
b"build_id_for_current_task",
"continue_as_new_suggested",
b"continue_as_new_suggested",
"history_length",
Expand Down
Loading

0 comments on commit 07f7cdc

Please sign in to comment.