Skip to content

Commit cb10cd8

Browse files
committed
revert public API change
1 parent f6dc487 commit cb10cd8

File tree

3 files changed

+7
-5
lines changed

3 files changed

+7
-5
lines changed

internal/internal_event_handlers.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -377,8 +377,8 @@ func (wc *workflowEnvironmentImpl) RegisterCancelHandler(handler func()) {
377377
func (wc *workflowEnvironmentImpl) ExecuteChildWorkflow(
378378
params executeWorkflowParams, callback resultHandler, startedHandler func(r WorkflowExecution, e error)) error {
379379
if params.workflowID == "" {
380-
if wc.workflowInfo.OriginalRunID != "" {
381-
params.workflowID = wc.workflowInfo.OriginalRunID + "_" + wc.GenerateSequenceID()
380+
if wc.workflowInfo.OriginalRunId != "" {
381+
params.workflowID = wc.workflowInfo.OriginalRunId + "_" + wc.GenerateSequenceID()
382382
} else {
383383
params.workflowID = wc.workflowInfo.WorkflowExecution.RunID + "_" + wc.GenerateSequenceID()
384384
}

internal/internal_task_handlers.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -631,7 +631,7 @@ func (wth *workflowTaskHandlerImpl) createWorkflowContext(task *s.PollForDecisio
631631
ID: workflowID,
632632
RunID: runID,
633633
},
634-
OriginalRunID: attributes.GetOriginalExecutionRunId(),
634+
OriginalRunId: attributes.GetOriginalExecutionRunId(),
635635
WorkflowType: flowWorkflowTypeFrom(*task.WorkflowType),
636636
TaskListName: taskList.GetName(),
637637
ExecutionStartToCloseTimeoutSeconds: attributes.GetExecutionStartToCloseTimeoutSeconds(),

internal/workflow.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1105,8 +1105,10 @@ func getWorkflowHeader(ctx Context, ctxProps []ContextPropagator) *s.Header {
11051105

11061106
// WorkflowInfo information about currently executing workflow
11071107
type WorkflowInfo struct {
1108-
WorkflowExecution WorkflowExecution
1109-
OriginalRunID string // The original runID before resetting. Using it instead of current runID can make workflow decision determinstic after reset
1108+
WorkflowExecution WorkflowExecution
1109+
// The original runID before resetting. Using it instead of current runID can make workflow decision determinstic after reset
1110+
// revive:disable-next-line this is an public field that is already exposed
1111+
OriginalRunId string
11101112
WorkflowType WorkflowType
11111113
TaskListName string
11121114
ExecutionStartToCloseTimeoutSeconds int32

0 commit comments

Comments
 (0)