From b913d67edd04369ad462187778ae10885f2a2f65 Mon Sep 17 00:00:00 2001 From: Alex Shtin Date: Thu, 11 May 2023 17:20:28 -0700 Subject: [PATCH] Remove unneeded duration/seconds conversion --- service/history/transferQueueActiveTaskExecutor_test.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/service/history/transferQueueActiveTaskExecutor_test.go b/service/history/transferQueueActiveTaskExecutor_test.go index 83c362b441c..2f0ccb7fc01 100644 --- a/service/history/transferQueueActiveTaskExecutor_test.go +++ b/service/history/transferQueueActiveTaskExecutor_test.go @@ -2638,10 +2638,10 @@ func (s *transferQueueActiveTaskExecutorSuite) createAddWorkflowTaskRequest( Kind: enumspb.TASK_QUEUE_KIND_NORMAL, } executionInfo := mutableState.GetExecutionInfo() - timeout := timestamp.DurationValue(executionInfo.WorkflowRunTimeout) + timeout := executionInfo.WorkflowRunTimeout if mutableState.GetExecutionInfo().TaskQueue != task.TaskQueue { taskQueue.Kind = enumspb.TASK_QUEUE_KIND_STICKY - timeout = timestamp.DurationValue(executionInfo.StickyScheduleToStartTimeout) + timeout = executionInfo.StickyScheduleToStartTimeout } return &matchingservice.AddWorkflowTaskRequest{ @@ -2652,7 +2652,7 @@ func (s *transferQueueActiveTaskExecutorSuite) createAddWorkflowTaskRequest( }, TaskQueue: taskQueue, ScheduledEventId: task.ScheduledEventID, - ScheduleToStartTimeout: &timeout, + ScheduleToStartTimeout: timeout, Clock: vclock.NewVectorClock(s.mockClusterMetadata.GetClusterID(), s.mockShard.GetShardID(), task.TaskID), } }