Skip to content

Commit a87e1c9

Browse files
authored
RerunParentInstanceInfo (#22)
* RerunParentInstanceInfo Adds a new message to orchestrator_service.proto to track parent orchestration instance info for rerun operations. Adds this message as an optional field to the two events which can be rerun from- `TimerCreatedEvent` and `TaskScheduledEvent`. ```proto // RerunParentInstanceInfo is used to indicate that this orchestration was // started as part of a rerun operation. Contains information about the parent // orchestration instance which was rerun. message RerunParentInstanceInfo { // instanceID is the orchestration instance ID this orchestration has been // rerun from. string instanceID = 1; } message TimerCreatedEvent { google.protobuf.Timestamp fireAt = 1; optional string name = 2; // If defined, indicates that this task was scheduled as part of a rerun // operation. optional RerunParentInstanceInfo rerunParentInstanceInfo = 3; } message TaskScheduledEvent { string name = 1; google.protobuf.StringValue version = 2; google.protobuf.StringValue input = 3; TraceContext parentTraceContext = 4; string taskExecutionId = 5; // If defined, indicates that this task was scheduled as part of a rerun // operation. optional RerunParentInstanceInfo rerunParentInstanceInfo = 6; } ``` Signed-off-by: joshvanl <[email protected]> * Comment: be more explicit of the rerun Signed-off-by: joshvanl <[email protected]> --------- Signed-off-by: joshvanl <[email protected]>
1 parent 6fc6b3e commit a87e1c9

File tree

1 file changed

+17
-0
lines changed

1 file changed

+17
-0
lines changed

protos/orchestrator_service.proto

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,15 @@ message ParentInstanceInfo {
6767
optional string appID = 5;
6868
}
6969

70+
// RerunParentInstanceInfo is used to indicate that this orchestration was
71+
// started as part of a rerun operation. Contains information about the parent
72+
// orchestration instance which was rerun.
73+
message RerunParentInstanceInfo {
74+
// instanceID is the orchestration instance ID this orchestration has been
75+
// rerun from.
76+
string instanceID = 1;
77+
}
78+
7079
message TraceContext {
7180
string traceParent = 1;
7281
string spanID = 2 [deprecated=true];
@@ -102,6 +111,10 @@ message TaskScheduledEvent {
102111
google.protobuf.StringValue input = 3;
103112
TraceContext parentTraceContext = 4;
104113
string taskExecutionId = 5;
114+
115+
// If defined, indicates that this task was the starting point of a new
116+
// workflow execution as the result of a rerun operation.
117+
optional RerunParentInstanceInfo rerunParentInstanceInfo = 6;
105118
}
106119

107120
message TaskCompletedEvent {
@@ -137,6 +150,10 @@ message SubOrchestrationInstanceFailedEvent {
137150
message TimerCreatedEvent {
138151
google.protobuf.Timestamp fireAt = 1;
139152
optional string name = 2;
153+
154+
// If defined, indicates that this task was the starting point of a new
155+
// workflow execution as the result of a rerun operation.
156+
optional RerunParentInstanceInfo rerunParentInstanceInfo = 3;
140157
}
141158

142159
message TimerFiredEvent {

0 commit comments

Comments
 (0)