Handle sync workflow state task in replication dlq handler
@@ -299,6 +299,18 @@ func (r *dlqHandlerImpl) readMessagesWithAckLevel(
NextEventId: task.NextEventID,
ScheduledEventId: 0,
})
+ case *tasks.SyncWorkflowStateTask:
+ taskInfo = append(taskInfo, &replicationspb.ReplicationTaskInfo{
+ NamespaceId: task.NamespaceID,
+ WorkflowId: task.WorkflowID,
+ RunId: task.RunID,
+ TaskType: enumsspb.TASK_TYPE_REPLICATION_SYNC_WORKFLOW_STATE,
+ TaskId: task.TaskID,
+ Version: task.Version,
+ FirstEventId: 0,
+ NextEventId: 0,
+ ScheduledEventId: 0,
+ })
default:
panic(fmt.Sprintf("Unknown repication task type: %v", task))
}
