Skip to content

Commit efb3bc1

Browse files
authored
Fix redirect replicate workflow state (#3809)
1 parent 0a90b77 commit efb3bc1

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

service/history/replication/task_executor.go

+1
Original file line numberDiff line numberDiff line change
@@ -321,6 +321,7 @@ func (e *taskExecutorImpl) handleSyncWorkflowStateTask(
321321
// This might be extra cost if the workflow belongs to local shard.
322322
// Add a wrapper of the history client to call history engine directly if it becomes an issue.
323323
_, err = e.shardContext.GetHistoryClient().ReplicateWorkflowState(ctx, &historyservice.ReplicateWorkflowStateRequest{
324+
NamespaceId: namespaceID.String(),
324325
WorkflowState: attr.GetWorkflowState(),
325326
RemoteCluster: e.remoteCluster,
326327
})

0 commit comments

Comments
 (0)