Bugfix: close execution request goes to Kafka even when visibility queue type is set to internalWithDualProcessor
@@ -290,7 +290,7 @@ func (t *transferQueueTaskExecutorBase) recordWorkflowClosed(
archiveVisibility = clusterConfiguredForVisibilityArchival && namespaceConfiguredForVisibilityArchival
}
- if (t.config.VisibilityQueue() == common.VisibilityQueueKafka || t.config.VisibilityQueue() == common.VisibilityQueueInternalWithDualProcessor) && recordWorkflowClose {
+ if t.config.VisibilityQueue() == common.VisibilityQueueKafka && recordWorkflowClose {
if err := t.visibilityMgr.RecordWorkflowExecutionClosed(&persistence.RecordWorkflowExecutionClosedRequest{
VisibilityRequestBase: &persistence.VisibilityRequestBase{
NamespaceID: namespaceID,
