Populate activityDispatchInfo with timestamps needed for local activi…

…ty dispatch by worker (cadence-workflow#3669)
gaecom · Oct 20, 2020 · e533892 · e533892
1 parent 6890e42
commit e533892
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/service/history/decisionTaskHandler.go b/service/history/decisionTaskHandler.go
@@ -249,6 +249,9 @@ func (handler *decisionTaskHandlerImpl) handleDecisionScheduleActivity(
 			if _, err1 := handler.mutableState.AddActivityTaskStartedEvent(ai, event.GetEventId(), uuid.New(), handler.identity); err1 != nil {
 				return nil, err1
 			}
+			activityDispatchInfo.ScheduledTimestamp = common.Int64Ptr(ai.ScheduledTime.UnixNano())
+			activityDispatchInfo.ScheduledTimestampOfThisAttempt = common.Int64Ptr(ai.ScheduledTime.UnixNano())
+			activityDispatchInfo.StartedTimestamp = common.Int64Ptr(ai.StartedTime.UnixNano())
 			return &decisionResult{activityDispatchInfo: activityDispatchInfo}, nil
 		}
 		return nil, nil