On replayer use task queue from history (#1023)

temporalio · Jan 31, 2023 · 093eabe · 093eabe
1 parent 6e8a39a
commit 093eabe
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/internal/internal_worker.go b/internal/internal_worker.go
@@ -1289,6 +1289,10 @@ func (aw *WorkflowReplayer) replayWorkflowHistory(logger log.Logger, service wor
 		execution.RunId = first.GetWorkflowExecutionStartedEventAttributes().GetOriginalExecutionRunId()
 	}
 
+	if first.GetWorkflowExecutionStartedEventAttributes().GetTaskQueue().GetName() != "" {
+		taskQueue = first.GetWorkflowExecutionStartedEventAttributes().GetTaskQueue().GetName()
+	}
+
 	task := &workflowservice.PollWorkflowTaskQueueResponse{
 		Attempt:                1,
 		TaskToken:              []byte("ReplayTaskToken"),