Make the failover end time check compatible with original value (#3450)

cadence-workflow · Aug 12, 2020 · 60c3463 · 60c3463
1 parent 68a0fe2
commit 60c3463
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/common/persistence/cassandra/cassandraMetadataPersistenceV2.go b/common/persistence/cassandra/cassandraMetadataPersistenceV2.go
@@ -434,7 +434,7 @@ func (m *cassandraMetadataPersistenceV2) GetDomain(request *p.GetDomainRequest)
 	replicationConfig.Clusters = p.GetOrUseDefaultClusters(m.currentClusterName, replicationConfig.Clusters)
 
 	var responseFailoverEndTime *int64
-	if failoverEndTime != emptyFailoverEndTime {
+	if failoverEndTime > emptyFailoverEndTime {
 		domainFailoverEndTime := failoverEndTime
 		responseFailoverEndTime = common.Int64Ptr(domainFailoverEndTime)
 	}
@@ -515,7 +515,7 @@ func (m *cassandraMetadataPersistenceV2) ListDomains(request *p.ListDomainsReque
 			domain.ReplicationConfig.Clusters = p.DeserializeClusterConfigs(replicationClusters)
 			domain.ReplicationConfig.Clusters = p.GetOrUseDefaultClusters(m.currentClusterName, domain.ReplicationConfig.Clusters)
 
-			if failoverEndTime != emptyFailoverEndTime {
+			if failoverEndTime > emptyFailoverEndTime {
 				domainFailoverEndTime := failoverEndTime
 				domain.FailoverEndTime = common.Int64Ptr(domainFailoverEndTime)
 			}