diff --git a/internal/compatibility/proto/request.go b/internal/compatibility/proto/request.go
index 10cebdeb8..42de7c8be 100644
--- a/internal/compatibility/proto/request.go
+++ b/internal/compatibility/proto/request.go
@@ -76,8 +76,9 @@ func DescribeWorkflowExecutionRequest(t *shared.DescribeWorkflowExecutionRequest
 		return nil
 	}
 	return &apiv1.DescribeWorkflowExecutionRequest{
-		Domain:            t.GetDomain(),
-		WorkflowExecution: WorkflowExecution(t.Execution),
+		Domain:                t.GetDomain(),
+		WorkflowExecution:     WorkflowExecution(t.Execution),
+		QueryConsistencyLevel: QueryConsistencyLevel(t.QueryConsistencyLevel),
 	}
 }
 
@@ -104,6 +105,7 @@ func GetWorkflowExecutionHistoryRequest(t *shared.GetWorkflowExecutionHistoryReq
 		WaitForNewEvent:        t.GetWaitForNewEvent(),
 		HistoryEventFilterType: EventFilterType(t.HistoryEventFilterType),
 		SkipArchival:           t.GetSkipArchival(),
+		QueryConsistencyLevel:  QueryConsistencyLevel(t.QueryConsistencyLevel),
 	}
 }
 
diff --git a/internal/compatibility/testdata/service.go b/internal/compatibility/testdata/service.go
index 599de45bf..0c667ec18 100644
--- a/internal/compatibility/testdata/service.go
+++ b/internal/compatibility/testdata/service.go
@@ -443,8 +443,9 @@ var (
 		Identity:          Identity,
 	}
 	DescribeWorkflowExecutionRequest = apiv1.DescribeWorkflowExecutionRequest{
-		Domain:            DomainName,
-		WorkflowExecution: &WorkflowExecution,
+		Domain:                DomainName,
+		WorkflowExecution:     &WorkflowExecution,
+		QueryConsistencyLevel: QueryConsistencyLevel,
 	}
 	DescribeWorkflowExecutionResponse = apiv1.DescribeWorkflowExecutionResponse{
 		ExecutionConfiguration: &WorkflowExecutionConfiguration,
@@ -504,6 +505,7 @@ var (
 		WaitForNewEvent:        true,
 		HistoryEventFilterType: HistoryEventFilterType,
 		SkipArchival:           true,
+		QueryConsistencyLevel:  QueryConsistencyLevel,
 	}
 	GetWorkflowExecutionHistoryResponse = apiv1.GetWorkflowExecutionHistoryResponse{
 		History:       &History,
diff --git a/internal/compatibility/thrift/request.go b/internal/compatibility/thrift/request.go
index bea585712..efd07f563 100644
--- a/internal/compatibility/thrift/request.go
+++ b/internal/compatibility/thrift/request.go
@@ -78,8 +78,9 @@ func DescribeWorkflowExecutionRequest(t *apiv1.DescribeWorkflowExecutionRequest)
 		return nil
 	}
 	return &shared.DescribeWorkflowExecutionRequest{
-		Domain:    &t.Domain,
-		Execution: WorkflowExecution(t.WorkflowExecution),
+		Domain:                &t.Domain,
+		Execution:             WorkflowExecution(t.WorkflowExecution),
+		QueryConsistencyLevel: QueryConsistencyLevel(t.QueryConsistencyLevel),
 	}
 }
 
@@ -106,6 +107,7 @@ func GetWorkflowExecutionHistoryRequest(t *apiv1.GetWorkflowExecutionHistoryRequ
 		WaitForNewEvent:        &t.WaitForNewEvent,
 		HistoryEventFilterType: EventFilterType(t.HistoryEventFilterType),
 		SkipArchival:           &t.SkipArchival,
+		QueryConsistencyLevel:  QueryConsistencyLevel(t.QueryConsistencyLevel),
 	}
 }