Skip to content

Commit

Permalink
fix minor typo "loger" (#499)
Browse files Browse the repository at this point in the history
Co-authored-by: Vitaly <[email protected]>
Co-authored-by: Chad Retz <[email protected]>
  • Loading branch information
3 people authored Oct 6, 2021
1 parent e739f51 commit a4c4243
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions internal/internal_worker.go
Original file line number Diff line number Diff line change
Expand Up @@ -1074,21 +1074,21 @@ func (aw *WorkflowReplayer) ReplayWorkflowHistoryFromJSONFile(logger log.Logger,
// lastEventID(inclusive).
// Use for testing the backwards compatibility of code changes and troubleshooting workflows in a debugger.
// The logger is an optional parameter. Defaults to the noop logger.
func (aw *WorkflowReplayer) ReplayPartialWorkflowHistoryFromJSONFile(loger log.Logger, jsonfileName string, lastEventID int64) error {
func (aw *WorkflowReplayer) ReplayPartialWorkflowHistoryFromJSONFile(logger log.Logger, jsonfileName string, lastEventID int64) error {
history, err := extractHistoryFromFile(jsonfileName, lastEventID)

if err != nil {
return err
}

if loger == nil {
loger = ilog.NewDefaultLogger()
if logger == nil {
logger = ilog.NewDefaultLogger()
}

controller := gomock.NewController(ilog.NewTestReporter(loger))
controller := gomock.NewController(ilog.NewTestReporter(logger))
service := workflowservicemock.NewMockWorkflowServiceClient(controller)

return aw.replayWorkflowHistory(loger, service, ReplayNamespace, history)
return aw.replayWorkflowHistory(logger, service, ReplayNamespace, history)
}

// ReplayWorkflowExecution replays workflow execution loading it from Temporal service.
Expand Down Expand Up @@ -1122,7 +1122,7 @@ func (aw *WorkflowReplayer) ReplayWorkflowExecution(ctx context.Context, service
return aw.replayWorkflowHistory(logger, service, namespace, hResponse.History)
}

func (aw *WorkflowReplayer) replayWorkflowHistory(loger log.Logger, service workflowservice.WorkflowServiceClient, namespace string, history *historypb.History) error {
func (aw *WorkflowReplayer) replayWorkflowHistory(logger log.Logger, service workflowservice.WorkflowServiceClient, namespace string, history *historypb.History) error {
taskQueue := "ReplayTaskQueue"
events := history.Events
if events == nil {
Expand Down Expand Up @@ -1173,7 +1173,7 @@ func (aw *WorkflowReplayer) replayWorkflowHistory(loger log.Logger, service work
Namespace: namespace,
TaskQueue: taskQueue,
Identity: "replayID",
Logger: loger,
Logger: logger,
cache: cache,
}
taskHandler := newWorkflowTaskHandler(params, nil, aw.registry)
Expand Down

0 comments on commit a4c4243

Please sign in to comment.