Use consistency level ONE for visibility store reads
@@ -194,7 +194,7 @@ func (v *cassandraVisibilityPersistence) ListOpenWorkflowExecutions(
request.DomainUUID,
domainPartition,
common.UnixNanoToCQLTimestamp(request.EarliestStartTime),
- common.UnixNanoToCQLTimestamp(request.LatestStartTime))
+ common.UnixNanoToCQLTimestamp(request.LatestStartTime)).Consistency(v.lowConslevel)
iter := query.PageSize(request.PageSize).PageState(request.NextPageToken).Iter()
if iter == nil {
// TODO: should return a bad request error if the token is invalid
@@ -229,7 +229,7 @@ func (v *cassandraVisibilityPersistence) ListClosedWorkflowExecutions(
request.DomainUUID,
domainPartition,
common.UnixNanoToCQLTimestamp(request.EarliestStartTime),
- common.UnixNanoToCQLTimestamp(request.LatestStartTime))
+ common.UnixNanoToCQLTimestamp(request.LatestStartTime)).Consistency(v.lowConslevel)
iter := query.PageSize(request.PageSize).PageState(request.NextPageToken).Iter()
if iter == nil {
// TODO: should return a bad request error if the token is invalid
@@ -265,7 +265,7 @@ func (v *cassandraVisibilityPersistence) ListOpenWorkflowExecutionsByType(
domainPartition,
common.UnixNanoToCQLTimestamp(request.EarliestStartTime),
common.UnixNanoToCQLTimestamp(request.LatestStartTime),
- request.WorkflowTypeName)
+ request.WorkflowTypeName).Consistency(v.lowConslevel)
iter := query.PageSize(request.PageSize).PageState(request.NextPageToken).Iter()
if iter == nil {
// TODO: should return a bad request error if the token is invalid
@@ -301,7 +301,7 @@ func (v *cassandraVisibilityPersistence) ListClosedWorkflowExecutionsByType(
domainPartition,
common.UnixNanoToCQLTimestamp(request.EarliestStartTime),
common.UnixNanoToCQLTimestamp(request.LatestStartTime),
- request.WorkflowTypeName)
+ request.WorkflowTypeName).Consistency(v.lowConslevel)
iter := query.PageSize(request.PageSize).PageState(request.NextPageToken).Iter()
if iter == nil {
// TODO: should return a bad request error if the token is invalid
@@ -337,7 +337,7 @@ func (v *cassandraVisibilityPersistence) ListOpenWorkflowExecutionsByWorkflowID(
domainPartition,
common.UnixNanoToCQLTimestamp(request.EarliestStartTime),
common.UnixNanoToCQLTimestamp(request.LatestStartTime),
- request.WorkflowID)
+ request.WorkflowID).Consistency(v.lowConslevel)
iter := query.PageSize(request.PageSize).PageState(request.NextPageToken).Iter()
if iter == nil {
// TODO: should return a bad request error if the token is invalid
@@ -373,7 +373,7 @@ func (v *cassandraVisibilityPersistence) ListClosedWorkflowExecutionsByWorkflowI
domainPartition,
common.UnixNanoToCQLTimestamp(request.EarliestStartTime),
common.UnixNanoToCQLTimestamp(request.LatestStartTime),
- request.WorkflowID)
+ request.WorkflowID).Consistency(v.lowConslevel)
iter := query.PageSize(request.PageSize).PageState(request.NextPageToken).Iter()
if iter == nil {
// TODO: should return a bad request error if the token is invalid
@@ -409,7 +409,7 @@ func (v *cassandraVisibilityPersistence) ListClosedWorkflowExecutionsByStatus(
domainPartition,
common.UnixNanoToCQLTimestamp(request.EarliestStartTime),
common.UnixNanoToCQLTimestamp(request.LatestStartTime),
- request.Status)
+ request.Status).Consistency(v.lowConslevel)
iter := query.PageSize(request.PageSize).PageState(request.NextPageToken).Iter()
if iter == nil {
// TODO: should return a bad request error if the token is invalid
