Skip to content

Commit

Permalink
Add new_execution_run_id to some workflow completion events (#119)
Browse files Browse the repository at this point in the history
  • Loading branch information
dnr authored Aug 27, 2021
1 parent ff5e03e commit 760fa12
Showing 1 changed file with 7 additions and 0 deletions.
7 changes: 7 additions & 0 deletions temporal/api/history/v1/message.proto
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,7 @@ message WorkflowExecutionStartedEventAttributes {
google.protobuf.Duration workflow_run_timeout = 8 [(gogoproto.stdduration) = true];
// Timeout of a single workflow task.
google.protobuf.Duration workflow_task_timeout = 9 [(gogoproto.stdduration) = true];
// Run id of previous ContinueAsNew or retry or cron execution.
string continued_execution_run_id = 10;
temporal.api.enums.v1.ContinueAsNewInitiator initiator = 11;
temporal.api.failure.v1.Failure continued_failure = 12;
Expand All @@ -82,16 +83,22 @@ message WorkflowExecutionStartedEventAttributes {
message WorkflowExecutionCompletedEventAttributes {
temporal.api.common.v1.Payloads result = 1;
int64 workflow_task_completed_event_id = 2;
// If another run is started by cron, this contains the new run id.
string new_execution_run_id = 3;
}

message WorkflowExecutionFailedEventAttributes {
temporal.api.failure.v1.Failure failure = 1;
temporal.api.enums.v1.RetryState retry_state = 2;
int64 workflow_task_completed_event_id = 3;
// If another run is started by cron or retry, this contains the new run id.
string new_execution_run_id = 4;
}

message WorkflowExecutionTimedOutEventAttributes {
temporal.api.enums.v1.RetryState retry_state = 1;
// If another run is started by cron or retry, this contains the new run id.
string new_execution_run_id = 2;
}

message WorkflowExecutionContinuedAsNewEventAttributes {
Expand Down

0 comments on commit 760fa12

Please sign in to comment.