Make logging fields consistent

cschleiden · cschleiden · commit 105a7873efed · 2022-07-27T17:06:58.000Z
diff --git a/internal/workflow/executor.go b/internal/workflow/executor.go
@@ -116,7 +116,7 @@ func (e *executor) ExecuteTask(ctx context.Context, t *task.Workflow) (*Executio
 			e.workflowCompleted(nil, err)
 			skipNewEvents = true
 		} else if t.LastSequenceID != e.lastSequenceID {
-			logger.Debug("Task has newer history than current state", "task_sequence_id", t.LastSequenceID, "sequence_id", e.lastSequenceID)
+			logger.Error("After replaying history, task still has newer history than current state", "task_sequence_id", t.LastSequenceID, "local_sequence_id", e.lastSequenceID)
 
 			return nil, errors.New("even after fetching history and replaying history executor state does not match task")
 		}

Original file line number	Diff line number	Diff line change
`@@ -116,7 +116,7 @@ func (e executor) ExecuteTask(ctx context.Context, t task.Workflow) (*Executio`
`116`	`116`	`e.workflowCompleted(nil, err)`
`117`	`117`	`skipNewEvents = true`
`118`	`118`	`} else if t.LastSequenceID != e.lastSequenceID {`
`119`		`- logger.Debug("Task has newer history than current state", "task_sequence_id", t.LastSequenceID, "sequence_id", e.lastSequenceID)`
	`119`	`+ logger.Error("After replaying history, task still has newer history than current state", "task_sequence_id", t.LastSequenceID, "local_sequence_id", e.lastSequenceID)`
`120`	`120`
`121`	`121`	`return nil, errors.New("even after fetching history and replaying history executor state does not match task")`
`122`	`122`	`}`