diff --git a/service/history/task/timer_active_task_executor.go b/service/history/task/timer_active_task_executor.go index e2602a0df54..e2b604ee19e 100644 --- a/service/history/task/timer_active_task_executor.go +++ b/service/history/task/timer_active_task_executor.go @@ -598,6 +598,7 @@ func (t *timerActiveTaskExecutor) executeActivityRetryTimerTask( TaskList: taskList, ScheduleID: scheduledID, ScheduleToStartTimeoutSeconds: common.Int32Ptr(scheduleToStartTimeout), + PartitionConfig: mutableState.GetExecutionInfo().PartitionConfig, }) } diff --git a/service/history/task/timer_active_task_executor_test.go b/service/history/task/timer_active_task_executor_test.go index d983170caec..8e5ae4043db 100644 --- a/service/history/task/timer_active_task_executor_test.go +++ b/service/history/task/timer_active_task_executor_test.go @@ -1067,6 +1067,7 @@ func (s *timerActiveTaskExecutorSuite) TestActivityRetryTimer_Fire() { }, ScheduleID: activityInfo.ScheduleID, ScheduleToStartTimeoutSeconds: common.Int32Ptr(activityInfo.ScheduleToStartTimeout), + PartitionConfig: mutableState.GetExecutionInfo().PartitionConfig, }, ).Return(nil).Times(1)